Bdf\Pipeline\Processor\StackProcessor

Complexity

Total Complexity

6

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	process()	0	9	2
A	buildCallable()	0	17	3
A	clearCache()	0	3	1

<?php

namespace Bdf\Pipeline\Processor;

use Bdf\Pipeline\ProcessorInterface;

/**
 * StackProcessor
 *
 * @author Sébastien Tanneux
 */
class StackProcessor implements ProcessorInterface
{
    /**
     * The pipes callable
     *
     * @var callable
     */
    private $callable;

    /**
     * {@inheritdoc}
     */
    public function process(array $pipes, array $payload, callable $outlet = null)
    {
        if ($this->callable === null) {
            $this->callable = $this->buildCallable($pipes, $outlet);
        }

        $callable = $this->callable;

        return $callable(...$payload);
    }

    /**
     * Build the chain callable
     *
     * @param array $pipes
     * @param callable|null $outlet
     *
     * @return \Closure
     */
    private function buildCallable($pipes, $outlet)
    {
        $callable = function (...$payload) use($outlet) {
            if ($outlet !== null) {
                return $outlet(...$payload);
            }

            return $payload[0] ?? null;
        };

        while ($pipe = array_pop($pipes)) {
            $callable = function (...$payload) use ($pipe, $callable) {
                return $pipe($callable, ...$payload);
            };
        }

        return $callable;
    }

    /**
     * {@inheritdoc}
     */
    public function clearCache()
    {
        $this->callable = null;
    }
}