Gielfeldt\Iterators\OrderedInterleaveIterator

Complexity

Total Complexity

15

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	0

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	2
A	setCompare()	0	5	1
A	compare()	0	4	1
A	defaultCompare()	0	4	1
A	add()	0	5	2
A	rewind()	0	14	4
A	key()	0	4	1
A	current()	0	4	1
A	next()	0	10	2

<?php

namespace Gielfeldt\Iterators;

class OrderedInterleaveIterator extends \SplHeap
{
    const DEFAULT_COMPARE = [__CLASS__, 'defaultCompare'];

    protected $iterators;
    protected $compareFunction = self::DEFAULT_COMPARE;


    public function __construct(\Traversable ...$iterators)
    {
        $this->iterators = new \ArrayIterator();
        foreach ($iterators as $iterator) {
            $this->add($iterator);
        }
    }

    public function setCompare($compareFunction)
    {
        $this->compareFunction = $compareFunction;
        return $this;
    }

    public function compare($a, $b)
    {
        return call_user_func_array($this->compareFunction, [$b[2], $a[2]]);
    }

    public function defaultCompare($a, $b)
    {
        return $a <=> $b;
    }

    public function add(\Traversable $iterator)
    {
        $this->iterators->append($iterator instanceof \Iterator ? $iterator : new \IteratorIterator($iterator));
        return $this;
    }

    public function rewind()
    {
        while (!$this->isEmpty()) {
            $this->extract();
        }
        foreach ($this->iterators as $no => $iterator) {
            $iterator->rewind();
            if ($iterator->valid()) {
                $this->insert([$no, $iterator->key(), $iterator->current()]);
                $iterator->next();
            }
        }
        $this->idx = 0;

The property idx does not exist. Did you maybe forget to declare it?

    }

    public function key()
    {
        return $this->top()[1];
    }

    public function current()
    {
        return $this->top()[2];
    }

    public function next()
    {
        $this->idx++;
        $used = $this->extract();
        $no = $used[0];
        if ($this->iterators[$no]->valid()) {
            $this->insert([$no, $this->iterators[$no]->key(), $this->iterators[$no]->current()]);
            $this->iterators[$no]->next();
        }
    }
}