Pipes\PipenessTrait

Complexity

Total Complexity

13

Size/Duplication

Total Lines	115
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	14

Importance

Changes	11
Bugs	2	Features	4

6 Methods

Rating	Name	Duplication	Size	Complexity
A	chainWith()	0	6	1
A	toArray()	0	6	1
A	toIterator()	0	13	2
A	unwrap()	0	6	2
B	getBaseOfChain()	0	26	5
A	executeCallback()	0	7	2

<?php

namespace Pipes;

use Pipes\Iterator\AppendIterator;

trait PipenessTrait
{
    //    use Filter\AppendTrait;
    use Filter\ChunkTrait;
    use Filter\EachTrait;
    use Concept\EmitTrait;
    use Filter\FilesTrait;
    use Filter\FilterTrait;
    use Filter\LimitTrait;
    use Filter\MapTrait;
    use Filter\SkipTrait;
    use Filter\ValuesTrait;
    use Filter\SleepTrait;
    use Filter\InfiniteTrait;
    use Filter\StopIfTrait;

    /**
     * @param \Iterator $iterator
     *
     * @return static
     */
    protected function chainWith(\Iterator $iterator)
    {
        $this->var = $iterator;

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

        return $this;
    }

    public function toArray()
    {
        $iterator = $this->var;

        return iterator_to_array($iterator, true);
    }

    /**
     * Returns a complete iterator.
     * (an instance of \IteratorIterator which in turn
     * implements \OuterIterator).
     *
     * Use this method if you need to comply with type-hinting
     * from external libraries
     *
     * @return \IteratorIterator
     */
    public function toIterator()
    {
        $iterator = $this->unwrap();

        if (is_array($iterator)) {
            $iterator = new \ArrayIterator($iterator);
        }

        $appendIterator = new AppendIterator();
        $appendIterator->append($iterator);

$iterator of type object<Traversable> is not a sub-type of object<Iterator>. It seems like you assume a child interface of the interface Traversable to be always present.

        return new PipeIterator($appendIterator);
    }

//    /**

40% of this comment could be valid code. Did you maybe forget this after debugging?

//     * @return \Traversable
//     */
//    protected function getRoot()
//    {
//        return $this->getBaseOfChain($this, true);
//    }

    /**
     * Returns the latest non pipe Iterator/Traversable in the
     * chain.
     *
     * @return \Traversable
     */
    public function unwrap()
    {
        $iterator = func_num_args() ? func_get_arg(0) : $this;

        return $this->getBaseOfChain($iterator);
    }

    public function getBaseOfChain($iterator, $pipeInstance = false)

The parameter $pipeInstance is not used and could be removed.

    {
        $last = $iterator;

$last is not used, you could remove the assignment.

        while (true) {
            switch (true) {
                case is_a($iterator, '\\Pipes\\PipeIterator'):
                    $last = $iterator;
                    $iterator = $last->getInnerIterator();
                    break;
                case is_a($iterator, '\\Pipes\\Pipe'):
                    $last = $iterator;
                    $iterator = $last->getIterator();
                    break;
                case is_a($iterator, '\\ArrayIterator'):
                    $iterator = $iterator->getArrayCopy();
                    break;
                default:
//                  --- was used by getRoot()

37% of this comment could be valid code. Did you maybe forget this after debugging?

//                    if ($pipeInstance) {
//                        return $last;
//                    }

                    return $iterator;
            }
        }
    } // @codeCoverageIgnore

    protected function executeCallback($______callback, $______allArgs, $value, $key, $iterator)
    {
        return call_user_func_array(
            $______callback,
            $______allArgs ? [$value, $key, $iterator] : [$value]
       );
    }
}