AlexManno\Remix\Pipelines\Pipeline

Complexity

Total Complexity

8

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	add()	0	11	2
A	count()	0	3	1
A	getStages()	0	3	1
A	__invoke()	0	9	2
A	pipe()	0	5	1

<?php

namespace AlexManno\Remix\Pipelines;

use AlexManno\Remix\Pipelines\Interfaces\PipelineInterface;
use AlexManno\Remix\Pipelines\Interfaces\StageInterface;
use AlexManno\Remix\Pipelines\Interfaces\PayloadInterface;
use SplQueue;

class Pipeline implements PipelineInterface
{
    /** @var SplQueue */
    private $stages;

    /**
     * Pipeline constructor.
     */
    public function __construct()
    {
        $this->stages = new SplQueue();
    }

    public function pipe(StageInterface $stage): PipelineInterface
    {
        $this->stages->enqueue($stage);

        return $this;
    }

    public function getStages(): \SplQueue
    {
        return $this->stages;
    }

    public function add(PipelineInterface $pipeline): PipelineInterface
    {
        $queue = $pipeline->getStages();

        $queue->rewind();
        while ($queue->valid()) {
            $this->stages->enqueue($queue->current());
            $queue->next();
        }

        return $this;
    }

    public function count(): int
    {
        return $this->stages->count();
    }

    public function __invoke(PayloadInterface $payload): PayloadInterface
    {
        $this->stages->rewind();
        while ($this->stages->valid()) {
            $payload = $this->stages->current()($payload);
            $this->stages->next();
        }

        return $payload;
    }
}