Phperf\Pipeline\Vector\Pipeline

Complexity

Total Complexity

6

Size/Duplication

Total Lines	32
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	addProcessor()	0	4	1
A	value()	0	14	4
A	getLastValue()	0	3	1

<?php

namespace Phperf\Pipeline\Vector;

class Pipeline implements VectorProcessor
{
    /** @var VectorProcessor[] */
    private $processors = [];

    public function addProcessor(VectorProcessor $processor)
    {
        $this->processors[] = $processor;
        return $this;
    }

    private $lastValue;

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

    public function value($value)
    {
        if ($value === null) {
            $this->lastValue = null;
            return null;
        }
        foreach ($this->processors as $processor) {
            $value = $processor->value($value);
            if ($value === null) {
                break;
            }
        }
        $this->lastValue = $value;
        return $value;
    }
}