phpinnacle / ensign

examples/cancel.php

Spacing +3 added lines, -3 removed lines

@@ -5,10 +5,10 @@ 
 
 require __DIR__ . '/../vendor/autoload.php';
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $dispatcher = new Dispatcher();
     $dispatcher
-        ->register('endless', function (string $sign) {
+        ->register('endless', function(string $sign) {
             while (true) {
                 yield new Delayed(100);
 
@@ -20,7 +20,7 @@ 
     try {
         $action = $dispatcher->dispatch('endless', '.');
 
-        Amp\Loop::delay(500, function () use ($action) {
+        Amp\Loop::delay(500, function() use ($action) {
             $action->cancel();
         });
 

examples/concurent.php

Spacing +3 added lines, -3 removed lines

@@ -5,10 +5,10 @@ 
 
 require __DIR__ . '/../vendor/autoload.php';
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $dispatcher = new Dispatcher();
     $dispatcher
-        ->register('emit', function (string $string, int $num, int $delay = 100) {
+        ->register('emit', function(string $string, int $num, int $delay = 100) {
             for ($i = 0; $i < $num; $i++) {
                 echo $string;
 
@@ -19,7 +19,7 @@ 
         })
     ;
 
-    $times   = \rand(5, 10);
+    $times = \rand(5, 10);
     $actionOne = $dispatcher->dispatch('emit', '-', $times, 100);
     $actionTwo = $dispatcher->dispatch('emit', '+', $times + \rand(5, 10), 100);
 

src/Exception/BadActionCall.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\Exception;
 

src/Action.php

Spacing +1 added lines, -1 removed lines

@@ -7,7 +7,7 @@
  * file that was distributed with this source code.
  */
 
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace PHPinnacle\Ensign;
 

src/Executor.php

Spacing +1 added lines, -1 removed lines

@@ -7,7 +7,7 @@
  * file that was distributed with this source code.
  */
 
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace PHPinnacle\Ensign;
 

src/Executor/ParallelExecutor.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\Executor;
 

src/Executor/SimpleExecutor.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\Executor;
 

src/Processor.php

Spacing +1 added lines, -1 removed lines

@@ -56,7 +56,7 @@
         $id = UUID::random();
 
         $token   = new Token($id);
-        $promise = new LazyPromise(function () use ($handler, $arguments, $token) {
+        $promise = new LazyPromise(function() use ($handler, $arguments, $token) {
             return $this->adapt($this->executor->execute($handler, $arguments), $token);
         });
 

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->processor->execute($listener, $message->arguments);
         }, $this->listeners[$message->signal] ?? []);
 
@@ -45,25 +45,25 @@ 
     }
 }
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $processor = new Processor();
     $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 '*';