FriendsOfSymfony / FOSElasticaBundle

        $this->assertTrue($called);

    }

    public function testShouldDispatchPreInsertObjectsEventWithExpectedArguments()

    {

        $objectPersisterMock = $this->createObjectPersisterMock();

        $options = ['indexName' => 'theIndex', 'typeName' => 'theType', 'batch_size' => 10];

        $registryMock = $this->createPersisterRegistryStub($objectPersisterMock);

        $dispatcher = new EventDispatcher();

        $persister = new InPlacePagerPersister($registryMock, $dispatcher);

        $objects = [new \stdClass(), new \stdClass()];

        $pager = $this->createPager($objects);

        $called = false;

        $dispatcher->addListener(Events::PRE_INSERT_OBJECTS, function($event) use(&$called, $pager, $objectPersisterMock, $objects, $options) {

            $called = true;

            $this->assertInstanceOf(PreInsertObjectsEvent::class, $event);

            $this->assertSame($pager, $event->getPager());

            $this->assertSame($objectPersisterMock, $event->getObjectPersister());

            $this->assertSame($options, $event->getOptions());

            $this->assertSame($objects, $event->getObjects());

        });

        $persister->insert($pager, $options);

        $this->assertTrue($called);

    }

    public function testShouldDispatchPostInsertObjectsEventWithExpectedArguments()

    {

        $this->assertTrue($called);

    }

    public function testShouldDispatchPostInsertObjectsEventWithExpectedArguments()

    {

        $objectPersisterMock = $this->createObjectPersisterMock();

        $options = ['indexName' => 'theIndex', 'typeName' => 'theType', 'batch_size' => 10];

        $registryMock = $this->createPersisterRegistryStub($objectPersisterMock);

        $dispatcher = new EventDispatcher();

        $persister = new InPlacePagerPersister($registryMock, $dispatcher);

        $objects = [new \stdClass(), new \stdClass()];

        $pager = $this->createPager($objects);

        $called = false;

        $dispatcher->addListener(Events::POST_INSERT_OBJECTS, function($event) use(&$called, $pager, $objectPersisterMock, $objects, $options) {

            $called = true;

            $this->assertInstanceOf(PostInsertObjectsEvent::class, $event);

            $this->assertSame($pager, $event->getPager());

            $this->assertSame($objectPersisterMock, $event->getObjectPersister());

            $this->assertSame($options, $event->getOptions());

            $this->assertSame($objects, $event->getObjects());

        });

        $persister->insert($pager, $options);

        $this->assertTrue($called);

    }

    public function testShouldDispatchPostPersistEventWithExpectedArguments()

    {

        $this->assertTrue($called);

    }

    public function testShouldDispatchPostPersistEventWithExpectedArguments()

    {

        $objectPersisterMock = $this->createObjectPersisterMock();

        $options = ['indexName' => 'theIndex', 'typeName' => 'theType', 'batch_size' => 10];

        $registryMock = $this->createPersisterRegistryStub($objectPersisterMock);

        $dispatcher = new EventDispatcher();

        $persister = new InPlacePagerPersister($registryMock, $dispatcher);

        $objects = [new \stdClass(), new \stdClass()];

        $pager = $this->createPager($objects);

        $called = false;

        $dispatcher->addListener(Events::POST_PERSIST, function($event) use(&$called, $pager, $objectPersisterMock, $objects, $options) {

            $called = true;

            $this->assertInstanceOf(PostPersistEvent::class, $event);

            $this->assertSame($pager, $event->getPager());

            $this->assertSame($objectPersisterMock, $event->getObjectPersister());

            $this->assertSame($options, $event->getOptions());

        });

        $persister->insert($pager, $options);

        $this->assertTrue($called);

    }

    public function testShouldCallObjectPersisterInsertManyMethodForEachPage()

    {