WyriHaximus / reactphp-child-process-messenger

src/StaticConfig.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
          * @psalm-suppress PossiblyNullReference
          */
         $arguments = (new ReflectionClass(Process::class))->getConstructor()->getParameters(); /** @phpstan-ignore-line */
-        if (! isset($arguments[self::EXPECTED_INDEX])) { /** @phpstan-ignore-line */
+        if (!isset($arguments[self::EXPECTED_INDEX])) { /** @phpstan-ignore-line */
             return $should = FALSE_;
         }
 

src/OutstandingCalls.php

Spacing +2 added lines, -2 removed lines

@@ -21,7 +21,7 @@ 
     {
         $uniqid = $this->getNewUniqid();
 
-        $this->calls[$uniqid] = new OutstandingCall($uniqid, $canceller, function (OutstandingCall $call): void {
+        $this->calls[$uniqid] = new OutstandingCall($uniqid, $canceller, function(OutstandingCall $call): void {
             unset($this->calls[$call->getUniqid()]);
         });
 
@@ -44,7 +44,7 @@ 
     private function getNewUniqid(): string
     {
         do {
-            $uniqid = (string) microtime(true) . '.' . bin2hex(random_bytes(4));
+            $uniqid = (string)microtime(true) . '.' . bin2hex(random_bytes(4));
         } while (array_key_exists($uniqid, $this->calls));
 
         return $uniqid;

src/Factory.php

Spacing +25 added lines, -25 removed lines

@@ -53,11 +53,11 @@ 
         LoopInterface $loop,
         array $options = []
     ): Promise\PromiseInterface {
-        return new Promise\Promise(static function (callable $resolve, callable $reject) use ($process, $loop, $options): void {
+        return new Promise\Promise(static function(callable $resolve, callable $reject) use ($process, $loop, $options): void {
             $server = new SocketServer('127.0.0.1:0', [], $loop);
 
             $options['random']  = bin2hex(random_bytes(32));
-            $options['address'] = (string) $server->getAddress();
+            $options['address'] = (string)$server->getAddress();
             $options            = new Options($options['random'], $options['address'], $options['connect-timeout'] ?? self::DEFAULT_CONNECT_TIMEOUT);
             $argvString         = escapeshellarg(ArgvEncoder::encode($options));
             $process            = new Process($process->getCommand() . ' ' . $argvString);
@@ -79,12 +79,12 @@ 
         LoopInterface $loop,
         array $options = []
     ): Promise\PromiseInterface {
-        if (! is_subclass_of($class, ChildInterface::class)) {
+        if (!is_subclass_of($class, ChildInterface::class)) {
             /** @phpstan-ignore-next-line */
             throw new Exception('Given class doesn\'t implement ChildInterface');
         }
 
-        return new Promise\Promise(static function (callable $resolve, callable $reject) use ($class, $loop, $options): void {
+        return new Promise\Promise(static function(callable $resolve, callable $reject) use ($class, $loop, $options): void {
             $template = '%s';
             if (array_key_exists('cmdTemplate', $options)) {
                 $template = $options['cmdTemplate'];
@@ -101,13 +101,13 @@ 
                 }
 
                 foreach ($fileDescriptorLister->list() as $id) {
-                    $fds[(int) $id] = ['file', '/dev/null', 'r'];
+                    $fds[(int)$id] = ['file', '/dev/null', 'r'];
                 }
             }
 
             $server         = new SocketServer('127.0.0.1:0', [], $loop);
             $connectTimeout = $options['connect-timeout'] ?? self::DEFAULT_CONNECT_TIMEOUT;
-            $options        = new Options(bin2hex(random_bytes(32)), (string) $server->getAddress(), $options['connect-timeout'] ?? self::DEFAULT_CONNECT_TIMEOUT);
+            $options        = new Options(bin2hex(random_bytes(32)), (string)$server->getAddress(), $options['connect-timeout'] ?? self::DEFAULT_CONNECT_TIMEOUT);
 
             $phpBinary        = escapeshellarg(PHP_BINARY . (PHP_SAPI === 'phpdbg' ? ' -qrr --' : ''));
             $childProcessPath = escapeshellarg(dirname(__DIR__) . DIRECTORY_SEPARATOR . 'bin' . DIRECTORY_SEPARATOR . 'child-process');
@@ -124,10 +124,10 @@ 
                 $fds
             );
 
-            futurePromise($loop)->then(static function () use ($process, $server, $loop, $options, $connectTimeout): Promise\PromiseInterface {
+            futurePromise($loop)->then(static function() use ($process, $server, $loop, $options, $connectTimeout): Promise\PromiseInterface {
                 return Promise\Timer\timeout(self::startParent($process, $server, $loop, $options), $connectTimeout, $loop);
-            })->then(static function (Messenger $messenger) use ($class): Promise\PromiseInterface {
-                return $messenger->rpc(MessengesFactory::rpc(Factory::PROCESS_REGISTER, ['className' => $class]))->then(static function () use ($messenger): Promise\PromiseInterface {
+            })->then(static function(Messenger $messenger) use ($class): Promise\PromiseInterface {
+                return $messenger->rpc(MessengesFactory::rpc(Factory::PROCESS_REGISTER, ['className' => $class]))->then(static function() use ($messenger): Promise\PromiseInterface {
                     return Promise\resolve($messenger);
                 });
             })->then($resolve, $reject);
@@ -141,9 +141,9 @@ 
     {
         $connectTimeout = $options->connectTimeout();
 
-        return (new Connector($loop, ['timeout' => $connectTimeout]))->connect($options->address())->then(static function (ConnectionInterface $connection) use ($options, $loop, $connectTimeout): Promise\PromiseInterface {
-            return new Promise\Promise(static function (callable $resolve, callable $reject) use ($connection, $options, $loop, $connectTimeout): void {
-                Promise\Timer\timeout(Promise\Stream\first($connection), $connectTimeout, $loop)->then(static function (string $chunk) use ($resolve, $reject, $connection, $options, $loop): void {
+        return (new Connector($loop, ['timeout' => $connectTimeout]))->connect($options->address())->then(static function(ConnectionInterface $connection) use ($options, $loop, $connectTimeout): Promise\PromiseInterface {
+            return new Promise\Promise(static function(callable $resolve, callable $reject) use ($connection, $options, $loop, $connectTimeout): void {
+                Promise\Timer\timeout(Promise\Stream\first($connection), $connectTimeout, $loop)->then(static function(string $chunk) use ($resolve, $reject, $connection, $options, $loop): void {
                     [$confirmation] = explode(PHP_EOL, $chunk);
                     if ($confirmation === 'syn') {
                         $connection->write('ack' . PHP_EOL);
@@ -158,9 +158,9 @@ 
                 }, $reject);
                 $connection->write(hash_hmac('sha512', $options->address(), $options->random()) . PHP_EOL);
             });
-        })->then(static function (Messenger $messenger) use ($loop, $termiteCallable): Messenger {
+        })->then(static function(Messenger $messenger) use ($loop, $termiteCallable): Messenger {
             if ($termiteCallable === null) {
-                $termiteCallable = static function () use ($loop): void {
+                $termiteCallable = static function() use ($loop): void {
                     $loop->addTimer(
                         self::TERMINATE_TIMEOUT,
                         [
@@ -173,7 +173,7 @@ 
 
             $messenger->registerRpc(
                 Messenger::TERMINATE_RPC,
-                static function (Payload $payload, Messenger $messenger) use ($termiteCallable): Promise\PromiseInterface {
+                static function(Payload $payload, Messenger $messenger) use ($termiteCallable): Promise\PromiseInterface {
                     $messenger->emit('terminate', [$messenger]);
                     $termiteCallable();
 
@@ -191,11 +191,11 @@ 
         LoopInterface $loop,
         Options $options
     ): Promise\PromiseInterface {
-        return (new Promise\Promise(static function (callable $resolve, callable $reject) use ($process, $server, $loop, $options): void {
+        return (new Promise\Promise(static function(callable $resolve, callable $reject) use ($process, $server, $loop, $options): void {
             $server->on(
                 'connection',
-                static function (ConnectionInterface $connection) use ($server, $resolve, $reject, $options): void {
-                    Promise\Stream\first($connection)->then(static function (string $chunk) use ($options, $connection): Promise\PromiseInterface {
+                static function(ConnectionInterface $connection) use ($server, $resolve, $reject, $options): void {
+                    Promise\Stream\first($connection)->then(static function(string $chunk) use ($options, $connection): Promise\PromiseInterface {
                         [$confirmation] = explode(PHP_EOL, $chunk);
                         if ($confirmation === hash_hmac('sha512', $options->address(), $options->random())) {
                             $connection->write('syn' . PHP_EOL);
@@ -204,32 +204,32 @@ 
                         }
 
                         return Promise\reject(new RuntimeException('Signature mismatch'));
-                    })->then(static function (string $chunk) use ($options, $connection): Promise\PromiseInterface {
+                    })->then(static function(string $chunk) use ($options, $connection): Promise\PromiseInterface {
                         [$confirmation] = explode(PHP_EOL, $chunk);
                         if ($confirmation === 'ack') {
                             return Promise\resolve(new Messenger($connection, $options));
                         }
 
                         return Promise\reject(new RuntimeException('Handshake failed'));
-                    })->then(static function (MessengerInterface $messenger) use ($server, $resolve): void {
+                    })->then(static function(MessengerInterface $messenger) use ($server, $resolve): void {
                         $server->close();
                         $resolve($messenger);
-                    }, static function (Throwable $throwable) use ($server, $reject): void {
+                    }, static function(Throwable $throwable) use ($server, $reject): void {
                         $server->close();
                         $reject($throwable);
                     });
                 }
             );
-            $server->on('error', static function (Throwable $et) use ($reject): void {
+            $server->on('error', static function(Throwable $et) use ($reject): void {
                 $reject($et);
             });
 
             $process->start($loop);
-        }, static function () use ($server, $process): void {
+        }, static function() use ($server, $process): void {
             $server->close();
             $process->terminate();
-        }))->then(static function (Messenger $messenger) use ($loop, $process): Messenger {
-            $loop->addPeriodicTimer(self::INTERVAL, static function (TimerInterface $timer) use ($messenger, $loop, $process): void {
+        }))->then(static function(Messenger $messenger) use ($loop, $process): Messenger {
+            $loop->addPeriodicTimer(self::INTERVAL, static function(TimerInterface $timer) use ($messenger, $loop, $process): void {
                 if ($process->isRunning()) {
                     return;
                 }

src/ChildProcess/Factory.php

Spacing +2 added lines, -2 removed lines

@@ -15,9 +15,9 @@
         $exitCode = 0;
 
         $loop = Loop::get();
-        MessengerFactory::child($loop, ArgvEncoder::decode($arguments))->then(static function (Messenger $messenger) use ($loop): void {
+        MessengerFactory::child($loop, ArgvEncoder::decode($arguments))->then(static function(Messenger $messenger) use ($loop): void {
             Process::create($loop, $messenger);
-        })->then(null, static function () use ($loop, &$exitCode): void {
+        })->then(null, static function() use ($loop, &$exitCode): void {
             $loop->stop();
             $exitCode = 1;
         });

src/ChildProcess/Process.php

Spacing +5 added lines, -5 removed lines

@@ -27,11 +27,11 @@ 
         $this->messenger = $messenger;
         $this->messenger->registerRpc(
             MessengerFactory::PROCESS_REGISTER,
-            function (Payload $payload): PromiseInterface {
+            function(Payload $payload): PromiseInterface {
                 /**
                  * @psalm-suppress PossiblyNullArgument
                  */
-                if (! is_subclass_of($payload['className'], ChildInterface::class)) {
+                if (!is_subclass_of($payload['className'], ChildInterface::class)) {
                     throw DoesNotImplementChildInterfaceException::create($payload['className'] ?? '');
                 }
 
@@ -45,9 +45,9 @@ 
 
     public static function create(LoopInterface $loop, Messenger $messenger): void
     {
-        $reject = static function (Throwable $exeption) use ($loop): void {
+        $reject = static function(Throwable $exeption) use ($loop): void {
 //            $messenger->error(MessagesFactory::error($exeption->getFile()));
-            $loop->addTimer(1, static function () use ($loop): void {
+            $loop->addTimer(1, static function() use ($loop): void {
                 $loop->stop();
             });
         };
@@ -61,7 +61,7 @@ 
 
     private function deregisterRpc(): void
     {
-        $this->loop->futureTick(function (): void {
+        $this->loop->futureTick(function(): void {
             $this->messenger->deregisterRpc(MessengerFactory::PROCESS_REGISTER);
         });
     }

examples/time-format/index.php

Spacing +4 added lines, -4 removed lines

@@ -10,14 +10,14 @@ 
 
 $loop = LoopFactory::create();
 
-MessengerFactory::parentFromClass(ExamplesChildProcess::class, $loop)->done(function (Messenger $messenger) use ($loop) {
+MessengerFactory::parentFromClass(ExamplesChildProcess::class, $loop)->done(function(Messenger $messenger) use ($loop) {
     $i = 0;
 
-    $messenger->on('error', function ($e) {
+    $messenger->on('error', function($e) {
         echo 'Error: ', \var_export($e, true), PHP_EOL;
     });
 
-    $loop->addPeriodicTimer(1, function (TimerInterface $timer) use ($messenger, &$i, $loop) {
+    $loop->addPeriodicTimer(1, function(TimerInterface $timer) use ($messenger, &$i, $loop) {
         if ($i >= 13) {
             $messenger->softTerminate();
             $loop->cancelTimer($timer);
@@ -27,7 +27,7 @@ 
 
         $messenger->rpc(MessageFactory::rpc('format', [
             'unixTime' => \time(),
-        ]))->then(function ($formattedTime) {
+        ]))->then(function($formattedTime) {
             echo $formattedTime['formattedTime'], PHP_EOL;
         });
         $i++;

examples/advanced-own-child-process/child.php

Spacing +2 added lines, -2 removed lines

@@ -18,8 +18,8 @@
 
 $arguments = \array_pop($argv);
 $loop = LoopFactory::create();
-MessengerFactory::child($loop, ArgvEncoder::decode($arguments))->done(function (Messenger $messenger) use ($loop) {
-    $messenger->registerRpc('hello', function (Payload $payload, Messenger $messenger) {
+MessengerFactory::child($loop, ArgvEncoder::decode($arguments))->done(function(Messenger $messenger) use ($loop) {
+    $messenger->registerRpc('hello', function(Payload $payload, Messenger $messenger) {
         \sleep(1);
 
         return \React\Promise\resolve([

examples/advanced-own-child-process/index.php

Spacing +4 added lines, -4 removed lines

@@ -11,15 +11,15 @@
 
 $loop = Factory::create();
 
-MessengerFactory::parent(new Process('exec php ' . __DIR__ . DIRECTORY_SEPARATOR . 'child.php foo bar'), $loop)->then(function (Messenger $messenger) {
+MessengerFactory::parent(new Process('exec php ' . __DIR__ . DIRECTORY_SEPARATOR . 'child.php foo bar'), $loop)->then(function(Messenger $messenger) {
     return $messenger->rpc(
         MessageFactory::rpc('hello')
-    )->always(function () use ($messenger) {
+    )->always(function() use ($messenger) {
         $messenger->softTerminate();
     });
-})->done(function (Payload $result) {
+})->done(function(Payload $result) {
     \var_export($result);
-}, function ($et) {
+}, function($et) {
     echo (string)$et;
 });
 

examples/return-class-messaging/index.php

Spacing +4 added lines, -4 removed lines

@@ -11,16 +11,16 @@
 
 $loop = EventLoopFactory::create();
 
-MessengerFactory::parentFromClass(\WyriHaximus\React\ChildProcess\Messenger\ReturnChild::class, $loop)->done(function (Messenger $messenger) use ($loop) {
-    $messenger->on('message', function ($message) {
+MessengerFactory::parentFromClass(\WyriHaximus\React\ChildProcess\Messenger\ReturnChild::class, $loop)->done(function(Messenger $messenger) use ($loop) {
+    $messenger->on('message', function($message) {
         echo 'Message: ', \var_export($message, true), 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) {
         echo 'tick', PHP_EOL;
         if ($i >= 13) {
             $loop->cancelTimer($timer);