phpinnacle / ensign

src/Processor/ParallelProcessor.php

Spacing +1 added lines, -1 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;
 

examples/parallel.php

Spacing +2 added lines, -2 removed lines

@@ -11,10 +11,10 @@
     exit(1);
 }
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $processor = new Processor\ParallelProcessor();
     $dispatcher = new Dispatcher(new Kernel($processor));
-    $dispatcher->register('load', function ($url) {
+    $dispatcher->register('load', function($url) {
         echo "Start getting: {$url}" . \PHP_EOL;
 
         file_get_contents($url);

examples/events.php

Spacing +5 added lines, -5 removed lines

@@ -37,7 +37,7 @@ 
 
     public function __invoke(Publish $message)
     {
-        $actions = \array_map(function ($listener) use ($message) {
+        $actions = \array_map(function($listener) use ($message) {
             return $this->kernel->execute($listener, $message->arguments);
         }, $this->listeners[$message->signal] ?? []);
 
@@ -45,25 +45,25 @@ 
     }
 }
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $kernel = new Kernel();
     $publisher = new Publisher($kernel);
     $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 '*';