FriendsOfSymfony / FOSElasticaBundle

        $this->assertTrue($called);

    }

    public function testShouldDispatchPreInsertObjectsEventWithExpectedArguments()

    {

        $objectPersisterMock = $this->createObjectPersisterMock();

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

        $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(

                ['batch_size' => 100, 'first_page' => 1, 'last_page' => 1] + $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'];

        $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(

                ['batch_size' => 100, 'first_page' => 1, 'last_page' => 1] + $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'];

        $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(

                ['batch_size' => 100, 'first_page' => 1, 'last_page' => 1] + $options,

                $event->getOptions()

            );

        });

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

        $this->assertTrue($called);

    }

    public function testShouldCallObjectPersisterInsertManyMethodForEachPage()

    {