@@ -39,7 +39,7 @@ discard block |
||
39 | 39 | { |
40 | 40 | $rest = array_slice(func_get_args(), 1); |
41 | 41 | |
42 | - return array_reduce($this->callbacks, function ($payload, $callback) use ($rest) { |
|
42 | + return array_reduce($this->callbacks, function($payload, $callback) use ($rest) { |
|
43 | 43 | return call_user_func_array($callback, array_merge([$payload], $rest)); |
44 | 44 | }, $payload); |
45 | 45 | } |
@@ -53,15 +53,15 @@ discard block |
||
53 | 53 | public function __call(callable $fn, array $args) |
54 | 54 | { |
55 | 55 | $ks = (new self()) |
56 | - ->pipe(new Filter(function ($x) { |
|
56 | + ->pipe(new Filter(function($x) { |
|
57 | 57 | return '%' === $x; |
58 | 58 | })) |
59 | - ->pipe(function ($xs) { |
|
59 | + ->pipe(function($xs) { |
|
60 | 60 | return array_keys($xs) ?: []; |
61 | 61 | }) |
62 | 62 | ->process($args); |
63 | 63 | |
64 | - return $this->pipe(function ($payload) use ($fn, $args, $ks) { |
|
64 | + return $this->pipe(function($payload) use ($fn, $args, $ks) { |
|
65 | 65 | if ([] === $ks) { |
66 | 66 | return call_user_func_array($fn, array_merge($args, [$payload])); |
67 | 67 | } |