Total Complexity | 8 |
Total Lines | 52 |
Duplicated Lines | 0 % |
Coverage | 100% |
Changes | 0 |
1 | <?php |
||
10 | class Pipeline implements PipelineInterface |
||
11 | { |
||
12 | /** @var SplQueue */ |
||
13 | private $stages; |
||
14 | |||
15 | /** |
||
16 | * Pipeline constructor. |
||
17 | */ |
||
18 | 5 | public function __construct() |
|
21 | 5 | } |
|
22 | |||
23 | 5 | public function pipe(StageInterface $stage): PipelineInterface |
|
24 | { |
||
25 | 5 | $this->stages->enqueue($stage); |
|
26 | |||
27 | 5 | return $this; |
|
28 | } |
||
29 | |||
30 | 1 | public function getStages(): \SplQueue |
|
31 | { |
||
32 | 1 | return $this->stages; |
|
33 | } |
||
34 | |||
35 | 1 | public function add(PipelineInterface $pipeline): PipelineInterface |
|
46 | } |
||
47 | |||
48 | 2 | public function count(): int |
|
51 | } |
||
52 | |||
53 | 3 | public function __invoke(PayloadInterface $payload): PayloadInterface |
|
62 | } |
||
63 | } |
||
64 |