Tests\BatchingIterator\BatchingIteratorTest

Complexity

Total Complexity

8

Size/Duplication

Total Lines	103
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	testWhenFetcherReturnsEmptyRightAway_iteratorIsEmpty()	0	11	1
A	testAllValuesEndUpInTheIterator()	0	9	1
A	batchSizeProvider()	0	9	1
A	testCorrectCallsAreMadeToTheBatchingFetcher()	0	26	1
A	testSettingInvalidMaxBatchSizeCausesException()	0	6	1
A	invalidBatchSizeProvider()	0	7	1
A	testWhenRewindingTheIterator_theFetcherIsAlsoRewinded()	0	10	1
A	testMultipleIteration()	0	8	1

<?php

declare( strict_types = 1 );

namespace Tests\BatchingIterator;

use BatchingIterator\BatchingIterator;
use BatchingIterator\Fetchers\InMemoryBatchingFetcher;
use PHPUnit\Framework\TestCase;

/**
 * @covers BatchingIterator\BatchingIterator
 *
 * @licence GNU GPL v2+
 * @author Jeroen De Dauw < jeroendedauw@gmail.com >
 */
class BatchingIteratorTest extends TestCase {

	public function testWhenFetcherReturnsEmptyRightAway_iteratorIsEmpty() {
		$fetcher = $this->createMock( 'BatchingIterator\BatchingFetcher' );

		$fetcher->expects( $this->once() )
			->method( 'fetchNext' )
			->will( $this->returnValue( [] ) );

		$iterator = new BatchingIterator( $fetcher );

$fetcher is of type object<PHPUnit\Framework\MockObject\MockObject>, but the function expects a object<BatchingIterator\BatchingFetcher>.

		$this->assertSame( [], iterator_to_array( $iterator ) );
	}

	/**
	 * @dataProvider batchSizeProvider
	 */
	public function testAllValuesEndUpInTheIterator( $batchSize ) {
		$values = [ 'foo', 'bar', 'baz', 'bah' ];

		$fetcher = new InMemoryBatchingFetcher( $values );
		$iterator = new BatchingIterator( $fetcher );
		$iterator->setMaxBatchSize( $batchSize );

		$this->assertSame( $values, iterator_to_array( $iterator ) );
	}

	public function batchSizeProvider() {
		return [
			[ 1 ],
			[ 2 ],
			[ 3 ],
			[ 10 ],
			[ 9001 ],
		];
	}

	public function testCorrectCallsAreMadeToTheBatchingFetcher() {
		$fetcher = $this->createMock( 'BatchingIterator\BatchingFetcher' );

		$fetcher->expects( $this->at( 0 ) )
			->method( 'rewind' );

		$fetcher->expects( $this->at( 1 ) )
			->method( 'fetchNext' )
			->with( $this->equalTo( 2 ) )
			->will( $this->returnValue( [ 'foo', 'bar' ] ) );

		$fetcher->expects( $this->at( 2 ) )
			->method( 'fetchNext' )
			->with( $this->equalTo( 2 ) )
			->will( $this->returnValue( [ 'baz' ] ) );

		$fetcher->expects( $this->at( 3 ) )
			->method( 'fetchNext' )
			->with( $this->equalTo( 2 ) )
			->will( $this->returnValue( [] ) );

		$iterator = new BatchingIterator( $fetcher );

$fetcher is of type object<PHPUnit\Framework\MockObject\MockObject>, but the function expects a object<BatchingIterator\BatchingFetcher>.

		$iterator->setMaxBatchSize( 2 );

		$this->assertSame( [ 'foo', 'bar', 'baz' ], iterator_to_array( $iterator ) );
	}

	/**
	 * @dataProvider invalidBatchSizeProvider
	 */
	public function testSettingInvalidMaxBatchSizeCausesException( $invalidBatchSize ) {
		$iterator = new BatchingIterator( $this->createMock( 'BatchingIterator\BatchingFetcher' ) );

$this->createMock('BatchingIterator\\BatchingFetcher') is of type object<PHPUnit\Framework\MockObject\MockObject>, but the function expects a object<BatchingIterator\BatchingFetcher>.

		$this->expectException( 'InvalidArgumentException' );
		$iterator->setMaxBatchSize( $invalidBatchSize );
	}

	public function invalidBatchSizeProvider() {
		return [
			[ 0 ],
			[ -1 ],
			[ -5 ],
		];
	}

	public function testWhenRewindingTheIterator_theFetcherIsAlsoRewinded() {
		$fetcher = $this->createMock( 'BatchingIterator\BatchingFetcher' );

		$fetcher->expects( $this->once() )
			->method( 'rewind' );

		$iterator = new BatchingIterator( $fetcher );

$fetcher is of type object<PHPUnit\Framework\MockObject\MockObject>, but the function expects a object<BatchingIterator\BatchingFetcher>.

		$iterator->rewind();
	}

	public function testMultipleIteration() {
		$values = [ 'foo', 'bar', 'baz' ];

		$iterator = new BatchingIterator( new InMemoryBatchingFetcher( $values ) );

		$this->assertEquals( $values, iterator_to_array( $iterator ) );
		$this->assertEquals( $values, iterator_to_array( $iterator ) );
	}

}