Graze\DataDb\Helper\ChunkedIterator

Complexity

Total Complexity

9

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
A	rewind()	0	6	1
A	key()	0	4	1
A	next()	0	9	3
A	current()	0	4	1
A	valid()	0	4	1

<?php

namespace Graze\DataDb\Helper;

use InvalidArgumentException;
use IteratorIterator;
use Traversable;

class ChunkedIterator extends IteratorIterator
{
    /** @var int Size of each chunk */
    protected $chunkSize;

    /** @var array Current chunk */
    protected $chunk;

    /** @var int */
    protected $key;

    /**
     * @param Traversable $iterator  Traversable iterator
     * @param int         $chunkSize Size to make each chunk
     */
    public function __construct(Traversable $iterator, $chunkSize)
    {
        $chunkSize = (int) $chunkSize;
        if ($chunkSize < 1) {
            throw new InvalidArgumentException("The chunk size must be equal or greater than zero; $chunkSize given");
        }
        parent::__construct($iterator);
        $this->chunkSize = $chunkSize;
    }

    public function rewind()
    {
        parent::rewind();
        $this->key = -1;
        $this->next();
    }

    /**
     * @return int|mixed
     */
    public function key()
    {
        return $this->key;
    }

    public function next()
    {
        $this->chunk = [];
        for ($i = 0; $i < $this->chunkSize && parent::valid(); $i++) {

It seems like you call parent on a different method (valid() instead of next()). Are you sure this is correct? If so, you might want to change this to $this->valid().

            $this->chunk[] = parent::current();

It seems like you call parent on a different method (current() instead of next()). Are you sure this is correct? If so, you might want to change this to $this->current().

            parent::next();
        }
        $this->key++;
    }

    /**
     * @return array
     */
    public function current()
    {
        return $this->chunk;
    }

    /**
     * @return bool
     */
    public function valid()
    {
        return (bool) $this->chunk;
    }
}