Pipeline::clear() - Code Metrics - Inspection of "Clear the callable if pipes has changed" - b2pweb/bdf-pipeline - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 783c9c...7d0a0b )

by Sébastien

created 2018-03-22 15:34 UTC

Pipeline::clear() A

↳ Parent: Pipeline

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	1
nc	1
nop	0
dl	0
loc	3
rs	10
c	0
b	0
f	0

<?php

namespace Bdf\Pipeline;

use Bdf\Pipeline\CallableFactory\StackCallableFactory;

/**
 * Pipeline
 *
 * @author Sébastien Tanneux
 */
final class Pipeline
{
    /**
     * The callable factory
     *
     * @var CallableFactoryInterface
     */
    private $factory;

    /**
     * The pipes
     *
     * @var callable[]
     */
    private $pipes = [];

    /**
     * The destination of the last pipe
     *
     * @var callable
     */
    private $outlet;

    /**
     * The built callable
     *
     * @var callable
     */
    private $callable;

    /**
     * Pipeline constructor.
     *
     * @param CallableFactoryInterface $factory
     */
    public function __construct(CallableFactoryInterface $factory = null)
    {
        $this->factory = $factory ?: new StackCallableFactory();
    }

    /**
     * Set the pipes
     *
     * @param callable[] $pipes
     *
     * @return $this
     */
    public function setPipes(array $pipes)
    {
        $this->clear();
        $this->pipes = $pipes;

        return $this;
    }

    /**
     * Add a pipe at the beginning of the chain
     *
     * @param callable $first
     *
     * @return $this
     */
    public function prepend($first)
    {
        $this->clear();
        array_unshift($this->pipes, $first);

        return $this;
    }

    /**
     * Add a pipe
     *
     * @param callable $last
     *
     * @return $this
     */
    public function pipe($last)
    {
        $this->clear();
        $this->pipes[] = $last;

        return $this;
    }

    /**
     * Set the pipeline outlet
     *
     * @param callable $outlet
     *
     * @return $this
     */
    public function outlet(callable $outlet)
    {
        $this->clear();
        $this->outlet = $outlet;

        return $this;
    }

    /**
     * Send the payload into the pipeline.
     *
     * @param array $payload
     *
     * @return mixed
     */
    public function send(...$payload)
    {
        if ($this->callable === null) {
            $this->callable = $this->factory->createCallable($this->pipes, $this->outlet);
        }

        $callable = $this->callable;
        return $callable(...$payload);
    }

    /**
     * Pipeline invokation
     *
     * @param array $payload
     *
     * @return mixed
     */
    public function __invoke(...$payload)
    {
        return $this->factory->callPipeline($this, $payload);
    }

    /**
     * Clear the callable
     */
    public function __clone()
    {
        $this->clear();
    }

    /**
     * Clear the callable
     */
    private function clear()
    {
        $this->callable = null;
    }
}


1			<?php
2
3			namespace Bdf\Pipeline;
4
5			use Bdf\Pipeline\CallableFactory\StackCallableFactory;
6
7			/**
8			* Pipeline
9			*
10			* @author Sébastien Tanneux
11			*/
12			final class Pipeline
13			{
14			/**
15			* The callable factory
16			*
17			* @var CallableFactoryInterface
18			*/
19			private $factory;
20
21			/**
22			* The pipes
23			*
24			* @var callable[]
25			*/
26			private $pipes = [];
27
28			/**
29			* The destination of the last pipe
30			*
31			* @var callable
32			*/
33			private $outlet;
34
35			/**
36			* The built callable
37			*
38			* @var callable
39			*/
40			private $callable;
41
42			/**
43			* Pipeline constructor.
44			*
45			* @param CallableFactoryInterface $factory
46			*/
47			public function __construct(CallableFactoryInterface $factory = null)
48			{
49			$this->factory = $factory ?: new StackCallableFactory();
50			}
51
52			/**
53			* Set the pipes
54			*
55			* @param callable[] $pipes
56			*
57			* @return $this
58			*/
59			public function setPipes(array $pipes)
60			{
61			$this->clear();
62			$this->pipes = $pipes;
63
64			return $this;
65			}
66
67			/**
68			* Add a pipe at the beginning of the chain
69			*
70			* @param callable $first
71			*
72			* @return $this
73			*/
74			public function prepend($first)
75			{
76			$this->clear();
77			array_unshift($this->pipes, $first);
78
79			return $this;
80			}
81
82			/**
83			* Add a pipe
84			*
85			* @param callable $last
86			*
87			* @return $this
88			*/
89			public function pipe($last)
90			{
91			$this->clear();
92			$this->pipes[] = $last;
93
94			return $this;
95			}
96
97			/**
98			* Set the pipeline outlet
99			*
100			* @param callable $outlet
101			*
102			* @return $this
103			*/
104			public function outlet(callable $outlet)
105			{
106			$this->clear();
107			$this->outlet = $outlet;
108
109			return $this;
110			}
111
112			/**
113			* Send the payload into the pipeline.
114			*
115			* @param array $payload
116			*
117			* @return mixed
118			*/
119			public function send(...$payload)
120			{
121			if ($this->callable === null) {
122			$this->callable = $this->factory->createCallable($this->pipes, $this->outlet);
123			}
124
125			$callable = $this->callable;
126			return $callable(...$payload);
127			}
128
129			/**
130			* Pipeline invokation
131			*
132			* @param array $payload
133			*
134			* @return mixed
135			*/
136			public function __invoke(...$payload)
137			{
138			return $this->factory->callPipeline($this, $payload);
139			}
140
141			/**
142			* Clear the callable
143			*/
144			public function __clone()
145			{
146			$this->clear();
147			}
148
149			/**
150			* Clear the callable
151			*/
152			private function clear()
153			{
154			$this->callable = null;
155			}
156			}
157

b2pweb / bdf-pipeline

Push — master ( 783c9c...7d0a0b )

Pipeline::clear() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like