phpinnacle / ensign

examples/events.php

Spacing +5 added lines, -5 removed lines

@@ -39,32 +39,32 @@
     {
         $listeners = $this->listeners[$message->signal] ?? [];
 
-        yield \array_map(function ($listener) use ($message) {
+        yield \array_map(function($listener) use ($message) {
             return $this->processor->execute($listener, $message->arguments);
         }, $listeners);
     }
 }
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $processor = new Processor\SimpleProcessor();
 
     $publisher = new Publisher($processor);
     $publisher
-        ->listen('print', function ($num) {
+        ->listen('print', function($num) {
             for ($i = 0; $i < $num; $i++) {
                 echo '-';
 
                 yield new Delayed(100);
             }
         })
-        ->listen('print', function ($num) {
+        ->listen('print', function($num) {
             for ($i = 0; $i < $num; $i++) {
                 echo '+';
 
                 yield new Delayed(100);
             }
         })
-        ->listen('print', function ($num) {
+        ->listen('print', function($num) {
             for ($i = 0; $i < $num; $i++) {
                 echo '*';
 

examples/pool.php

Spacing +2 added lines, -2 removed lines

@@ -5,10 +5,10 @@
 
 require __DIR__ . '/../vendor/autoload.php';
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $processor = new Processor\ParallelProcessor();
     $dispatcher = new Dispatcher($processor);
-    $dispatcher->register('load', function ($url) {
+    $dispatcher->register('load', function($url) {
         echo "Start getting: {$url}" . \PHP_EOL;
 
         file_get_contents($url);

src/functions.php

Spacing +2 added lines, -2 removed lines

@@ -8,7 +8,7 @@ 
  * file that was distributed with this source code.
  */
 
-declare(strict_types = 1);
+declare(strict_types=1);
 
 use PHPinnacle\Ensign\Dispatcher;
 use PHPinnacle\Ensign\Action;
@@ -56,7 +56,7 @@ 
             continue;
         }
 
-        $handler = static function (string $watcherId, int $sigNo, $sigInfo = null) use ($dispatcher, $signal) {
+        $handler = static function(string $watcherId, int $sigNo, $sigInfo = null) use ($dispatcher, $signal) {
             yield $dispatcher->dispatch($signal, $sigNo, $sigInfo, $watcherId);
         };
 

src/Processor/ParallelProcessor.php

Spacing +2 added lines, -2 removed lines

@@ -8,7 +8,7 @@ 
  * file that was distributed with this source code.
  */
 
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace PHPinnacle\Ensign\Processor;
 
@@ -47,7 +47,7 @@ 
      */
     protected function process(callable $handler, array $arguments, Token $token): callable
     {
-        return function () use ($handler, $arguments, $token) {
+        return function() use ($handler, $arguments, $token) {
             $parallel = ParallelFunctions\parallel($handler, $this->pool);
 
             return $parallel(...$arguments);

src/Processor/SimpleProcessor.php

Spacing +2 added lines, -2 removed lines

@@ -8,7 +8,7 @@ 
  * file that was distributed with this source code.
  */
 
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace PHPinnacle\Ensign\Processor;
 
@@ -23,7 +23,7 @@ 
      */
     protected function process(callable $handler, array $arguments, Token $token): callable
     {
-        return function () use ($handler, $arguments, $token) {
+        return function() use ($handler, $arguments, $token) {
             return $this->adapt($handler(...$arguments), $token);
         };
     }