League\Pipeline\PipelineBuilder

Complexity

Total Complexity

6

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	pipe()	0	7	1
A	fork()	0	6	1
A	processor()	0	4	1
A	buildLast()	0	6	2
A	build()	0	5	1

<?php

namespace League\Pipeline;

use Illuminate\Database\Schema\Builder;

class PipelineBuilder implements PipelineBuilderInterface
{
    /**
     * @var callable[]
     */
    protected $stages = [];

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

    /**
     * @var BuilderInterface
     */
    private $last;

    /**
     * Add an stage.
     *
     * @param callable $stage
     *
     * @return $this
     */
    public function pipe(callable $stage)
    {
        $this->buildLast();
        $this->stages[] = $stage;

        return $this;
    }

    public function fork(callable $resolver)
    {
        $this->buildLast();
        $this->last = new ForkBuilder($resolver, $this);
        return $this->last;
    }

    public function processor(ProcessorInterface $processor)
    {
        $this->processr = $processor;
    }

    private function buildLast()
    {
        if($this->last == null) return;
        $this->stages[] = $this->last->build();
        $this->last = null;
    }

    /**
     * Build a new Pipeline object
     *
     * @return Pipeline
     */
    public function build()
    {
        $this->buildLast();
        return new Pipeline($this->stages, $this->processr);
    }
}