@@ -3,5 +3,5 @@ |
||
3 | 3 | namespace WyriHaximus\React; |
4 | 4 | |
5 | 5 | if (!\function_exists('WyriHaximus\React\childProcessPromiseClosure')) { |
6 | - require __DIR__ . '/functions.php'; |
|
6 | + require __DIR__.'/functions.php'; |
|
7 | 7 | } |
@@ -20,17 +20,17 @@ |
||
20 | 20 | */ |
21 | 21 | function childProcessPromiseClosure(LoopInterface $loop, Closure $closure): PromiseInterface |
22 | 22 | { |
23 | - return Factory::parentFromClass(ClosureChild::class, $loop)->then(function (Messenger $messenger) use ($closure) { |
|
23 | + return Factory::parentFromClass(ClosureChild::class, $loop)->then(function(Messenger $messenger) use ($closure) { |
|
24 | 24 | $deferred = new Deferred(); |
25 | - $messenger->on('error', function (Throwable $throwable) use ($deferred, $messenger): void { |
|
25 | + $messenger->on('error', function(Throwable $throwable) use ($deferred, $messenger): void { |
|
26 | 26 | $deferred->reject($throwable); |
27 | 27 | $messenger->softTerminate(); |
28 | 28 | }); |
29 | 29 | |
30 | - $messenger->rpc(MessageFactory::rpc($closure))->done(function (Payload $payload) use ($deferred, $messenger): void { |
|
30 | + $messenger->rpc(MessageFactory::rpc($closure))->done(function(Payload $payload) use ($deferred, $messenger): void { |
|
31 | 31 | $deferred->resolve($payload->getPayload()); |
32 | 32 | $messenger->softTerminate(); |
33 | - }, function (Throwable $throwable) use ($deferred, $messenger): void { |
|
33 | + }, function(Throwable $throwable) use ($deferred, $messenger): void { |
|
34 | 34 | $deferred->reject($throwable); |
35 | 35 | $messenger->softTerminate(); |
36 | 36 | }); |