League\Pipeline\Pipeline

Complexity

Total Complexity

5

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Test Coverage

Coverage

93.33%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	__invoke()	0	3	1
A	pipe()	0	6	1
A	process()	0	8	2

<?php
declare(strict_types=1);

namespace League\Pipeline;

class Pipeline implements PipelineInterface
{
    /**
     * @var callable[]
     */
    private $stages = [];

    /**
     * @var ProcessorInterface
     */
    private $processor;

    /**
     * Pipeline constructor.
     *
     * @param \League\Pipeline\ProcessorInterface|null $processor
     * @param callable ...$stages
     */
    public function __construct(ProcessorInterface $processor = null, callable ...$stages)
    {
        $this->processor = $processor ?? new FingersCrossedProcessor;
        $this->stages = $stages;
    }

    /**
     * One pipe for your task.
     *
     * @param callable $stage
     * @return \League\Pipeline\PipelineInterface|$this
     */
    public function pipe(callable $stage): PipelineInterface
    {
        $pipeline = clone $this;
        $pipeline->stages[] = $stage;

        return $pipeline;
    }

    public function process($payload, ...$params)
    {
        if ($this->processor instanceof ParametersInterface) {
            $this->processor->setParameters(...$params);
            return $this->processor->process($payload, ...$this->stages);
        }

        return $this->processor->process($payload, ...$this->stages);
    }

    public function __invoke($payload, ...$params)
    {
        return $this->process($payload, ...$params);
    }
}