Bdf\Pipeline\Pipe

Complexity

Total Complexity

6

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setNext()	0	3	1
A	getNext()	0	3	1
A	__invoke()	0	3	1
A	__construct()	0	4	1
A	__clone()	0	4	2

<?php

namespace Bdf\Pipeline;

/**
 * Pipe
 *
 * @internal
 *
 * @author Johnmeurt
 */
final class Pipe
{
    /**
     * The callback processor
     *
     * @var ProcessorInterface
     */
    private $processor;

    /**
     * The pipe callback
     *
     * @var callable
     */
    private $callback;

    /**
     * The pipe chain
     *
     * @var callable
     */
    private $next;

    /**
     * PipeInterface constructor
     *
     * @param ProcessorInterface $processor
     * @param callable $callback
     */
    public function __construct(ProcessorInterface $processor, callable $callback)
    {
        $this->processor = $processor;
        $this->callback = $callback;
    }

    /**
     * Set the next pipe
     *
     * @param callable $pipe
     */
    public function setNext(callable $pipe)
    {
        $this->next = $pipe;
    }

    /**
     * Get the next pipe
     *
     * @return callable
     */
    public function getNext()
    {
        return $this->next;
    }

    /**
     * Invoke pipe
     *
     * @param array $payload
     *
     * @return mixed
     */
    public function __invoke(...$payload)
    {
        return $this->processor->process($this->callback, $payload, $this->next);
    }

    /**
     * Clone the pipe
     */
    public function __clone()
    {
        if ($this->next instanceof self) {
            $this->next = clone $this->next;
        }
    }
}