Pipeline::process() - Code Metrics - Inspection of "Pass any variables between stages" - thephpleague/pipeline - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#45)

by Roquie

created 2018-06-13 18:33 UTC

Pipeline::process() A

↳ Parent: Pipeline

Complexity

Conditions	2
Paths	2

Size

Total Lines	8
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	2.032

Importance

Changes

Metric	Value
cc	2
eloc	4
nc	2
nop	2
dl	0
loc	8
ccs	4
cts	5
cp	0.8
crap	2.032
rs	9.4285
c	0
b	0
f	0

<?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);
    }
}


1		<?php
2		declare(strict_types=1);
3
4		namespace League\Pipeline;
5
6		class Pipeline implements PipelineInterface
7		{
8		/**
9		* @var callable[]
10		*/
11		private $stages = [];
12
13		/**
14		* @var ProcessorInterface
15		*/
16		private $processor;
17
18		/**
19		* Pipeline constructor.
20		*
21		* @param \League\Pipeline\ProcessorInterface\|null $processor
22		* @param callable ...$stages
23		*/
24	14	public function __construct(ProcessorInterface $processor = null, callable ...$stages)
25		{
26	14	$this->processor = $processor ?? new FingersCrossedProcessor;
27	14	$this->stages = $stages;
28	14	}
29
30		/**
31		* One pipe for your task.
32		*
33		* @param callable $stage
34		* @return \League\Pipeline\PipelineInterface\|$this
35		*/
36	8	public function pipe(callable $stage): PipelineInterface
37		{
38	8	$pipeline = clone $this;
39	8	$pipeline->stages[] = $stage;
40
41	8	return $pipeline;
42		}
43
44	10	public function process($payload, ...$params)
45		{
46	10	if ($this->processor instanceof ParametersInterface) {
47	10	$this->processor->setParameters(...$params);
48	10	return $this->processor->process($payload, ...$this->stages);
49		}
50
51		return $this->processor->process($payload, ...$this->stages);
52		}
53
54	4	public function __invoke($payload, ...$params)
55		{
56	4	return $this->process($payload, ...$params);
57		}
58		}
59

thephpleague / pipeline

Pull Request — master (#45)

Pipeline::process() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like