Completed
Push — master ( 5eae02...fa730f )
by Nate
01:29
created

Processor::process()   A

Complexity

Conditions 2
Paths 1

Size

Total Lines 4
Code Lines 2

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 0
CRAP Score 6

Importance

Changes 0
Metric Value
dl 0
loc 4
ccs 0
cts 4
cp 0
rs 10
c 0
b 0
f 0
cc 2
eloc 2
nc 1
nop 3
crap 6
1
<?php
2
3
/**
4
 * @copyright  Copyright (c) Flipbox Digital Limited
5
 * @license    https://github.com/flipbox/pipeline/blob/master/LICENSE.md
6
 * @link       https://github.com/flipbox/pipeline
7
 */
8
9
namespace Flipbox\Pipeline\Processors;
10
11
use League\Pipeline\ProcessorInterface;
12
13
/**
14
 * A base pipeline built for extensibility
15
 *
16
 * @author Flipbox Digital <[email protected]>
17
 * @since 1.0.0
18
 */
19
class Processor implements ProcessorInterface
20
{
21
    /**
22
     * @param array $stages
23
     * @param mixed $payload
24
     * @param mixed|null $source
25
     *
26
     * @return mixed
27
     */
28
    public function process(array $stages, $payload, $source = null)
29
    {
30
        return $this->processStages($stages, $payload, $source ?: $payload);
31
    }
32
33
    /**
34
     * @param array $stages
35
     * @param mixed $payload
36
     * @param mixed $source
37
     *
38
     * @return mixed
39
     */
40
    protected function processStages(array $stages, $payload, $source)
41
    {
42
        foreach ($stages as $stage) {
43
            $payload = $this->processStage($stage, $payload, $source);
44
        }
45
46
        return $payload;
47
    }
48
49
    /**
50
     * @param callable $stage
51
     * @param mixed $payload
52
     * @param mixed|null $source
53
     * @return mixed
54
     */
55
    protected function processStage(callable $stage, $payload, $source = null)
56
    {
57
        return call_user_func_array($stage, [$payload, $source]);
58
    }
59
}
60