WyriHaximus / reactphp-child-process-messenger

benchmark/memory.php

Spacing +8 added lines, -8 removed lines

@@ -8,10 +8,10 @@ 
     echo '------------------------------------------', PHP_EOL;
     echo $message, PHP_EOL;
     echo '------------------------------------------', PHP_EOL;
-    echo 'Current memory usage: ',      \memory_get_usage()          / MB, 'MB', PHP_EOL;
-    echo 'Peak memory usage: ',         \memory_get_peak_usage()     / MB, 'MB', PHP_EOL;
-    echo 'Current real memory usage: ', \memory_get_usage(true)      / MB, 'MB', PHP_EOL;
-    echo 'Peak real memory usage: ',    \memory_get_peak_usage(true) / MB, 'MB', PHP_EOL;
+    echo 'Current memory usage: ', \memory_get_usage() / MB, 'MB', PHP_EOL;
+    echo 'Peak memory usage: ', \memory_get_peak_usage() / MB, 'MB', PHP_EOL;
+    echo 'Current real memory usage: ', \memory_get_usage(true) / MB, 'MB', PHP_EOL;
+    echo 'Peak real memory usage: ', \memory_get_peak_usage(true) / MB, 'MB', PHP_EOL;
 }
 
 show_memory('Bare init');
@@ -28,20 +28,20 @@ 
 
 $loop = EventLoopFactory::create();
 
-MessengerFactory::parentFromClass(\WyriHaximus\React\ChildProcess\Messenger\ReturnChild::class, $loop)->then(function (Messenger $messenger) use ($loop) {
-    $messenger->on('error', function ($e) {
+MessengerFactory::parentFromClass(\WyriHaximus\React\ChildProcess\Messenger\ReturnChild::class, $loop)->then(function(Messenger $messenger) use ($loop) {
+    $messenger->on('error', function($e) {
         echo 'Error: ', \var_export($e, true), PHP_EOL;
     });
 
     $i = 0;
-    $loop->addPeriodicTimer(0.00001, function (TimerInterface $timer) use (&$i, $messenger, $loop) {
+    $loop->addPeriodicTimer(0.00001, function(TimerInterface $timer) use (&$i, $messenger, $loop) {
         if ($i >= I) {
             $loop->cancelTimer($timer);
             $messenger->softTerminate();
 
             show_memory('Completed messaging');
 
-            $loop->addTimer(5, function () {
+            $loop->addTimer(5, function() {
             });
 
             return;

src/Messages/RpcError.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
 
     public function handle(MessengerInterface $bindTo, string $source): void
     {
-        $cb = Closure::fromCallable(function (Throwable $payload, string $uniqid): void {
+        $cb = Closure::fromCallable(function(Throwable $payload, string $uniqid): void {
             /**
              * @psalm-suppress UndefinedMethod
              */

src/Messages/Error.php

Spacing +2 added lines, -2 removed lines

@@ -36,11 +36,11 @@
 
     public function handle(object $bindTo, string $source): void
     {
-        $cb = function (Throwable $payload): void {
+        $cb = function(Throwable $payload): void {
             /**
              * @psalm-suppress UndefinedMethod
              */
-            $this->emit('error', [ /** @phpstan-ignore-line  */
+            $this->emit('error', [/** @phpstan-ignore-line  */
                 $payload,
                 $this,
             ]);

src/Messages/Rpc.php

Spacing +5 added lines, -5 removed lines

@@ -52,11 +52,11 @@ 
 
     public function handle(object $bindTo, string $source): void
     {
-        $cb = Closure::fromCallable(function (string $target, Payload $payload, string $uniqid): void {
+        $cb = Closure::fromCallable(function(string $target, Payload $payload, string $uniqid): void {
             /**
              * @psalm-suppress UndefinedMethod
              */
-            if (! $this->hasRpc($target)) { /** @phpstan-ignore-line  */
+            if (!$this->hasRpc($target)) { /** @phpstan-ignore-line  */
                 $this->write($this->createLine(Factory::rpcError($uniqid, new Exception(sprintf('Rpc target <%s> doesn\'t exist', $target))))); /** @phpstan-ignore-line  */
 
                 return;
@@ -65,14 +65,14 @@ 
             /**
              * @psalm-suppress UndefinedMethod
              */
-            $this->callRpc($target, $payload)->done( /** @phpstan-ignore-line  */
-                function (array $payload) use ($uniqid): void {
+            $this->callRpc($target, $payload)->done(/** @phpstan-ignore-line  */
+                function(array $payload) use ($uniqid): void {
                     /**
                      * @psalm-suppress UndefinedMethod
                      */
                     $this->write($this->createLine(Factory::rpcSuccess($uniqid, $payload))); /** @phpstan-ignore-line  */
                 },
-                function (Throwable $error) use ($uniqid): void {
+                function(Throwable $error) use ($uniqid): void {
                     /**
                      * @psalm-suppress UndefinedMethod
                      */

src/Messages/LineEncoder.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
         $throwables = [];
         $line       = Hash::flatten($line);
         foreach ($line as $key => $value) {
-            if (! ($value instanceof Throwable)) {
+            if (!($value instanceof Throwable)) {
                 continue;
             }
 

src/Messages/RpcSuccess.php

Spacing +1 added lines, -1 removed lines

@@ -39,7 +39,7 @@
 
     public function handle(MessengerInterface $bindTo, string $source): void
     {
-        $cb = Closure::fromCallable(function (Payload $payload, string $uniqid): void {
+        $cb = Closure::fromCallable(function(Payload $payload, string $uniqid): void {
             /**
              * @psalm-suppress UndefinedMethod
              */

src/Messages/Message.php

Spacing +2 added lines, -2 removed lines

@@ -33,11 +33,11 @@
 
     public function handle(object $bindTo, string $source): void
     {
-        $cb = function (Payload $payload): void {
+        $cb = function(Payload $payload): void {
             /**
              * @psalm-suppress UndefinedMethod
              */
-            $this->emit('message', [ /** @phpstan-ignore-line  */
+            $this->emit('message', [/** @phpstan-ignore-line  */
                 $payload,
                 $this,
             ]);

src/Messenger.php

Spacing +4 added lines, -4 removed lines

@@ -65,12 +65,12 @@ 
 
         $this->outstandingRpcCalls = new OutstandingCalls();
 
-        $this->connection->on('data', function (string $data): void {
+        $this->connection->on('data', function(string $data): void {
             $this->buffer .= $data;
             $this->emit('data', [$data]);
             $this->handleData();
         });
-        $this->connection->on('close', function (): void {
+        $this->connection->on('close', function(): void {
             $calls = $this->outstandingRpcCalls->getCalls();
             if (count($calls) === 0) {
                 return;
@@ -127,7 +127,7 @@ 
 
     public function rpc(Rpc $rpc): PromiseInterface
     {
-        $callReference = $this->outstandingRpcCalls->newCall(function (): void {}); // phpcs:disabled
+        $callReference = $this->outstandingRpcCalls->newCall(function(): void {}); // phpcs:disabled
 
         $this->write($this->createLine($rpc->setUniqid($callReference->getUniqid())));
 
@@ -141,7 +141,7 @@ 
         /**
          * @psalm-suppress InvalidCast
          */
-        return (string) new $lineCLass($line, $this->options['lineOptions']);
+        return (string)new $lineCLass($line, $this->options['lineOptions']);
     }
 
     public function softTerminate(): PromiseInterface

src/ReturnChild.php

Spacing +2 added lines, -2 removed lines

@@ -16,10 +16,10 @@
     /** @phpstan-ignore-next-line */
     private function __construct(Messenger $messenger, LoopInterface $loop)
     {
-        $messenger->registerRpc('return', static function (Payload $payload): PromiseInterface {
+        $messenger->registerRpc('return', static function(Payload $payload): PromiseInterface {
             return resolve($payload->getPayload());
         });
-        $messenger->on('message', static function (Payload $payload) use ($messenger): void {
+        $messenger->on('message', static function(Payload $payload) use ($messenger): void {
             $messenger->message(MessagesFactory::message($payload->getPayload()));
         });
     }