Ghc\Rosetta\Pipeline

Complexity

Total Complexity

6

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	flow()	0	8	2
A	pushPipe()	0	9	3

<?php

namespace Ghc\Rosetta;

use Ghc\Rosetta\Pipes\Pipeable;

class Pipeline
{
    use Configurable;

    /**
     * @var \Closure[]
     */
    protected $pipes = [];

    /**
     * Pipeline constructor.
     *
     * @param array $config
     */
    public function __construct($config = [])
    {
        $this->setConfig($config);
    }

    public function pushPipe($pipe, $options = [])
    {
        if ($pipe instanceof Pipeable) {
            $this->pipes[] = $pipe->pipe($options);
        } elseif ($pipe instanceof \Closure) {
            $this->pipes[] = $pipe;
        }

        return $this;
    }

    public function flow($data = null)
    {
        foreach ($this->pipes as $pipe) {
            /** @var \Closure $pipe */
            $data = $pipe($data);
        }

        return $data;
    }
}