1 | <?php |
||
16 | trait RowProcessor |
||
17 | { |
||
18 | /** |
||
19 | * @var callable[] |
||
20 | */ |
||
21 | protected $processors = []; |
||
22 | |||
23 | /** |
||
24 | * Add a processor |
||
25 | * |
||
26 | * @param callable $processor |
||
27 | * |
||
28 | * @return static |
||
29 | */ |
||
30 | 33 | public function addProcessor(callable $processor) |
|
36 | |||
37 | /** |
||
38 | * Go through all the processors |
||
39 | * |
||
40 | * @param array $row |
||
41 | * |
||
42 | * @return array |
||
43 | */ |
||
44 | 20 | public function process(array $row) |
|
45 | { |
||
46 | 20 | foreach ($this->processors as $processor) { |
|
47 | 20 | $row = call_user_func($processor, $row); |
|
48 | } |
||
49 | |||
50 | 20 | return $row; |
|
51 | } |
||
52 | |||
53 | /** |
||
54 | * Remove a processor |
||
55 | * |
||
56 | * @param callable $processor |
||
57 | * |
||
58 | * @return static |
||
59 | */ |
||
60 | 1 | public function removeProcessor(callable $processor) |
|
61 | { |
||
62 | 1 | $res = array_search($processor, $this->processors, true); |
|
63 | 1 | if ($res !== false) { |
|
64 | 1 | unset($this->processors[$res]); |
|
65 | } |
||
66 | |||
67 | 1 | return $this; |
|
68 | } |
||
69 | |||
70 | /** |
||
71 | * Check if a processor has already been added |
||
72 | * |
||
73 | * @param callable $processor |
||
74 | * |
||
75 | * @return bool |
||
76 | */ |
||
77 | 2 | public function hasProcessor(callable $processor) |
|
81 | } |
||
82 |