@@ -38,7 +38,7 @@ discard block |
||
| 38 | 38 | * @param array $pipes |
| 39 | 39 | * @param ProcessorInterface $processor |
| 40 | 40 | */ |
| 41 | - public function __construct(array $pipes = [], ProcessorInterface $processor = null) |
|
| 41 | + public function __construct(array $pipes = [ ], ProcessorInterface $processor = null) |
|
| 42 | 42 | { |
| 43 | 43 | $this->processor = $processor ?: new StackProcessor(); |
| 44 | 44 | $this->pipes = $pipes; |
@@ -61,7 +61,7 @@ discard block |
||
| 61 | 61 | */ |
| 62 | 62 | public function pipe($last) |
| 63 | 63 | { |
| 64 | - $this->pipes[] = $last; |
|
| 64 | + $this->pipes[ ] = $last; |
|
| 65 | 65 | } |
| 66 | 66 | |
| 67 | 67 | /** |
@@ -42,16 +42,16 @@ |
||
| 42 | 42 | */ |
| 43 | 43 | private function buildCallable($pipes, $outlet) |
| 44 | 44 | { |
| 45 | - $callable = function (...$payload) use($outlet) { |
|
| 45 | + $callable = function(...$payload) use($outlet) { |
|
| 46 | 46 | if ($outlet !== null) { |
| 47 | 47 | return $outlet(...$payload); |
| 48 | 48 | } |
| 49 | 49 | |
| 50 | - return $payload[0] ?? null; |
|
| 50 | + return $payload[ 0 ] ?? null; |
|
| 51 | 51 | }; |
| 52 | 52 | |
| 53 | 53 | while ($pipe = array_pop($pipes)) { |
| 54 | - $callable = function (...$payload) use ($pipe, $callable) { |
|
| 54 | + $callable = function(...$payload) use ($pipe, $callable) { |
|
| 55 | 55 | return $pipe($callable, ...$payload); |
| 56 | 56 | }; |
| 57 | 57 | } |
@@ -16,7 +16,7 @@ |
||
| 16 | 16 | */ |
| 17 | 17 | public function process(array $pipes, array $payload, callable $outlet = null) |
| 18 | 18 | { |
| 19 | - $payload = $payload[0] ?? null; |
|
| 19 | + $payload = $payload[ 0 ] ?? null; |
|
| 20 | 20 | |
| 21 | 21 | foreach ($pipes as $pipe) { |
| 22 | 22 | $payload = $pipe($payload); |