Bdf\Pipeline\Processor\PipeProcessor

Complexity

Total Complexity

4

Size/Duplication

Total Lines	25
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	clearCache()	0	2	1
A	process()	0	13	3

<?php

namespace Bdf\Pipeline\Processor;

use Bdf\Pipeline\ProcessorInterface;

/**
 * PipeProcessor
 *
 * @author Sébastien Tanneux
 */
class PipeProcessor implements ProcessorInterface
{
    /**
     * {@inheritdoc}
     */
    public function process(array $pipes, array $payload, callable $outlet = null)
    {
        $payload = $payload[0] ?? null;

        foreach ($pipes as $pipe) {
            $payload = $pipe($payload);
        }

        if ($outlet !== null) {
            return $outlet($payload);
        }

        return $payload;
    }

    /**
     * {@inheritdoc}
     */
    public function clearCache()
    {

    }
}