WyriHaximus / reactphp-child-process-messenger

examples/overflow/index.php

Spacing +4 added lines, -4 removed lines

@@ -10,15 +10,15 @@
 
 $loop = Factory::create();
 
-MessengerFactory::parentFromClass('\ExamplesChildProcess', $loop)->then(function (Messenger $messenger) {
+MessengerFactory::parentFromClass('\ExamplesChildProcess', $loop)->then(function(Messenger $messenger) {
     return $messenger->rpc(
         MessageFactory::rpc('overflow')
-    )->always(function () use ($messenger) {
+    )->always(function() use ($messenger) {
         $messenger->softTerminate();
     });
-})->done(function (Payload $result) {
+})->done(function(Payload $result) {
     throw new Exception('Should never reach this!');
-}, function ($et) {
+}, function($et) {
     echo (string)$et;
 });
 

examples/secure-messages/index.php

Spacing +4 added lines, -4 removed lines

@@ -18,17 +18,17 @@
 
 $loop = EventLoopFactory::create();
 
-MessengerFactory::parentFromClass(ExamplesChildProcess::class, $loop, $options)->then(function (Messenger $messenger) use ($loop) {
-    $messenger->on('message', function (Payload $payload) {
+MessengerFactory::parentFromClass(ExamplesChildProcess::class, $loop, $options)->then(function(Messenger $messenger) use ($loop) {
+    $messenger->on('message', function(Payload $payload) {
         echo $payload['time'], PHP_EOL;
     });
 
-    $messenger->on('error', function ($e) {
+    $messenger->on('error', function($e) {
         echo 'Error: ', \var_export($e, true), PHP_EOL;
     });
 
     $i = 0;
-    $loop->addPeriodicTimer(1, function (TimerInterface $timer) use (&$i, $messenger, $loop) {
+    $loop->addPeriodicTimer(1, function(TimerInterface $timer) use (&$i, $messenger, $loop) {
         if ($i >= 13) {
             $loop->cancelTimer($timer);
             $messenger->softTerminate();

examples/prime/index.php

Spacing +3 added lines, -3 removed lines

@@ -14,13 +14,13 @@
 
 echo 'Checking if ', $prime, ' is a prime or not', PHP_EOL;
 
-MessengerFactory::parentFromClass(ExamplesChildProcess::class, $loop)->then(function (Messenger $messenger) use ($prime) {
+MessengerFactory::parentFromClass(ExamplesChildProcess::class, $loop)->then(function(Messenger $messenger) use ($prime) {
     return $messenger->rpc(
         MessageFactory::rpc('isPrime', ['number' => $prime])
-    )->always(function () use ($messenger) {
+    )->always(function() use ($messenger) {
         $messenger->softTerminate();
     });
-})->done(function (Payload $result) {
+})->done(function(Payload $result) {
     if ($result['isPrime']) {
         echo 'Prime', PHP_EOL;
 

examples/ExamplesChildProcess.php

Spacing +5 added lines, -5 removed lines

@@ -10,26 +10,26 @@
 {
     public static function create(Messenger $messenger, LoopInterface $loop): void
     {
-        $messenger->registerRpc('error', function (Payload $payload) {
+        $messenger->registerRpc('error', function(Payload $payload) {
             throw new Exception('whoops');
         });
 
-        $messenger->registerRpc('isPrime', function (Payload $payload) {
+        $messenger->registerRpc('isPrime', function(Payload $payload) {
             return \React\Promise\resolve([
                 'isPrime' => self::isPrime($payload['number']),
             ]);
         });
-        $messenger->on('message', function (Payload $payload, Messenger $messenger) {
+        $messenger->on('message', function(Payload $payload, Messenger $messenger) {
             $messenger->message(MessagesFactory::message([
                 'time' => (new DateTime('@' . $payload['time'] * $payload['i']))->format('c'),
             ]));
         });
-        $messenger->registerRpc('format', function (Payload $payload) {
+        $messenger->registerRpc('format', function(Payload $payload) {
             return \React\Promise\resolve([
                 'formattedTime' => (new DateTime('@' . $payload['unixTime']))->format('c'),
             ]);
         });
-        $messenger->registerRpc('overflow', function () {
+        $messenger->registerRpc('overflow', function() {
             \ini_set('memory_limit', '20M');
 
             $string = '';

examples/messages/index.php

Spacing +4 added lines, -4 removed lines

@@ -11,17 +11,17 @@
 
 $loop = EventLoopFactory::create();
 
-MessengerFactory::parentFromClass(ExamplesChildProcess::class, $loop)->then(function (Messenger $messenger) use ($loop) {
-    $messenger->on('message', function (Payload $payload) {
+MessengerFactory::parentFromClass(ExamplesChildProcess::class, $loop)->then(function(Messenger $messenger) use ($loop) {
+    $messenger->on('message', function(Payload $payload) {
         echo $payload['time'], PHP_EOL;
     });
 
-    $messenger->on('error', function ($e) {
+    $messenger->on('error', function($e) {
         echo 'Error: ', \var_export($e, true), PHP_EOL;
     });
 
     $i = 0;
-    $loop->addPeriodicTimer(0.001, function (TimerInterface $timer) use (&$i, $messenger, $loop) {
+    $loop->addPeriodicTimer(0.001, function(TimerInterface $timer) use (&$i, $messenger, $loop) {
         if ($i >= 130) {
             $loop->cancelTimer($timer);
             $messenger->softTerminate();

examples/secure-return-class/index.php

Spacing +4 added lines, -4 removed lines

@@ -19,13 +19,13 @@ 
 
 $loop = EventLoopFactory::create();
 
-MessengerFactory::parentFromClass(ReturnChild::class, $loop, $options)->then(function (Messenger $messenger) use ($loop) {
-    $messenger->on('error', function ($e) {
+MessengerFactory::parentFromClass(ReturnChild::class, $loop, $options)->then(function(Messenger $messenger) use ($loop) {
+    $messenger->on('error', function($e) {
         echo 'Error: ', \var_export($e, true), PHP_EOL;
     });
 
     $i = 0;
-    $loop->addPeriodicTimer(1, function (TimerInterface $timer) use (&$i, $messenger, $loop) {
+    $loop->addPeriodicTimer(1, function(TimerInterface $timer) use (&$i, $messenger, $loop) {
         if ($i >= 13) {
             $loop->cancelTimer($timer);
             $messenger->softTerminate();
@@ -36,7 +36,7 @@ 
         $messenger->rpc(MessagesFactory::rpc('return', [
             'i' => $i,
             'time' => \time(),
-        ]))->then(function (Payload $payload) {
+        ]))->then(function(Payload $payload) {
             echo $payload['time'], PHP_EOL;
         });
 

examples/return-class/index.php

Spacing +4 added lines, -4 removed lines

@@ -12,13 +12,13 @@ 
 
 $loop = EventLoopFactory::create();
 
-MessengerFactory::parentFromClass(ReturnChild::class, $loop)->done(function (Messenger $messenger) use ($loop) {
-    $messenger->on('error', function ($e) {
+MessengerFactory::parentFromClass(ReturnChild::class, $loop)->done(function(Messenger $messenger) use ($loop) {
+    $messenger->on('error', function($e) {
         echo 'Error: ', \var_export($e, true), PHP_EOL;
     });
 
     $i = 0;
-    $loop->addPeriodicTimer(1, function (TimerInterface $timer) use (&$i, $messenger, $loop) {
+    $loop->addPeriodicTimer(1, function(TimerInterface $timer) use (&$i, $messenger, $loop) {
         echo 'tick', PHP_EOL;
         if ($i >= 13) {
             $loop->cancelTimer($timer);
@@ -30,7 +30,7 @@ 
         $messenger->rpc(MessagesFactory::rpc('return', [
             'i' => $i,
             'time' => \time(),
-        ]))->then(function (Payload $payload) {
+        ]))->then(function(Payload $payload) {
             var_export($payload);
             echo $payload['time'], PHP_EOL;
         });