Pipes\Iterator\ChunkIterator

Complexity

Total Complexity

10

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	3
Bugs	2	Features	1

6 Methods

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

<?php

/**
 * Derived by Guzzle's ChunkedIterator https://github.com/guzzle/iterator/blob/master/ChunkedIterator.php
 * credit goes to the original authors.
 */
namespace Pipes\Iterator;

use Traversable;

class ChunkIterator extends \IteratorIterator
{
    protected $key = 0;

    /** @var int Size of each chunk */
    protected $size;
    /** @var array Current chunk */
    protected $chunk;

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

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

    public function next()
    {
        $this->chunk = array();
        for ($i = 0; $i < $this->size && 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->chunk ? $this->key++ : null;
    }

    public function key()
    {
        return $this->key;
    }

    public function current()
    {
        return $this->chunk;
    }

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