@@ -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 | }); |