phpinnacle / ensign

examples/emit.php

Spacing +3 added lines, -3 removed lines

@@ -28,10 +28,10 @@ 
     }
 }
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $builder = new DispatcherBuilder;
     $builder
-        ->register(SimpleCommand::class, function (SimpleCommand $cmd) {
+        ->register(SimpleCommand::class, function(SimpleCommand $cmd) {
             yield new Delayed($cmd->delay); // Just do some heavy calculations
             yield SimpleEvent::class => new SimpleEvent($cmd->num + $cmd->num);
 
@@ -40,7 +40,7 @@ 
 
             return $cmd->num;
         })
-        ->register(SimpleEvent::class, function (SimpleEvent $event) {
+        ->register(SimpleEvent::class, function(SimpleEvent $event) {
             echo \sprintf('Signal dispatched with value: %d at %s' . \PHP_EOL, $event->num, \microtime(true));
         })
     ;

examples/ping-pong.php

Spacing +4 added lines, -4 removed lines

@@ -22,10 +22,10 @@ 
 {
 }
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $builder = new DispatcherBuilder;
     $builder
-        ->register(Ping::class, function (Ping $cmd) {
+        ->register(Ping::class, function(Ping $cmd) {
             if ($cmd->times > 0) {
                 $cmd->times--;
 
@@ -36,12 +36,12 @@ 
                 yield new Stop();
             }
         })
-        ->register(Pong::class, function (Pong $cmd) {
+        ->register(Pong::class, function(Pong $cmd) {
             echo 'Pong!' . \PHP_EOL;
 
             yield new Ping($cmd->times);
         })
-        ->register(Stop::class, function () {
+        ->register(Stop::class, function() {
             echo 'Stop!' . \PHP_EOL;
         })
     ;

examples/events.php

Spacing +4 added lines, -4 removed lines

@@ -5,24 +5,24 @@
 
 require __DIR__ . '/../vendor/autoload.php';
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $builder = new DispatcherBuilder;
     $builder
-        ->register('print', function ($num) {
+        ->register('print', function($num) {
             for ($i = 0; $i < $num; $i++) {
                 echo '-';
 
                 yield new Delayed(100);
             }
         })
-        ->register('print', function ($num) {
+        ->register('print', function($num) {
             for ($i = 0; $i < $num; $i++) {
                 echo '+';
 
                 yield new Delayed(100);
             }
         })
-        ->register('print', function ($num) {
+        ->register('print', function($num) {
             for ($i = 0; $i < $num; $i++) {
                 echo '*';
 

examples/process.php

Spacing +9 added lines, -9 removed lines

@@ -6,10 +6,10 @@ 
 
 require __DIR__ . '/../vendor/autoload.php';
 
-Amp\Loop::run(function () {
+Amp\Loop::run(function() {
     $handlers = new HandlerRegistry;
     $handlers
-        ->add('spawn', function (callable $process) {
+        ->add('spawn', function(callable $process) {
             static $pid = 1;
 
             $gen = $process($pid);
@@ -18,12 +18,12 @@ 
 
             return $pid++;
         })
-        ->add('send', function (int $pid, string $message, ...$arguments) {
+        ->add('send', function(int $pid, string $message, ...$arguments) {
             $signal = sprintf('%s.%d', $message, $pid);
 
             return yield $signal => $arguments;
         })
-        ->add('receive', function (int $pid, string $message, callable $handler) use ($handlers) {
+        ->add('receive', function(int $pid, string $message, callable $handler) use ($handlers) {
             $signal = sprintf('%s.%d', $message, $pid);
 
             $handlers->add($signal, $handler);
@@ -32,23 +32,23 @@ 
 
     $dispatcher = new Dispatcher($handlers);
 
-    $receiver = yield $dispatcher->dispatch('spawn', function (int $pid) {
-        yield 'receive' => [$pid, 'ping', function () {
+    $receiver = yield $dispatcher->dispatch('spawn', function(int $pid) {
+        yield 'receive' => [$pid, 'ping', function() {
             echo 'Ping!' . \PHP_EOL;
         }];
 
-        yield 'receive' => [$pid, 'pong', function () {
+        yield 'receive' => [$pid, 'pong', function() {
             echo 'Pong!' . \PHP_EOL;
         }];
     });
 
-    $senderOne = $dispatcher->dispatch('spawn', function () use ($receiver) {
+    $senderOne = $dispatcher->dispatch('spawn', function() use ($receiver) {
         yield 'send' => [$receiver, 'ping'];
         yield new Delayed(500);
         yield 'send' => [$receiver, 'ping'];
     });
 
-    $senderTwo = $dispatcher->dispatch('spawn', function () use ($receiver) {
+    $senderTwo = $dispatcher->dispatch('spawn', function() use ($receiver) {
         yield 'send' => [$receiver, 'pong'];
         yield new Delayed(100);
         yield 'send' => [$receiver, 'pong'];

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() {
     $builder = new DispatcherBuilder;
     $builder
-        ->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;
 
@@ -21,7 +21,7 @@ 
 
     $dispatcher = $builder->build();
 
-    $times   = \rand(5, 10);
+    $times = \rand(5, 10);
     $actionOne = $dispatcher->dispatch('emit', '-', $times, 100);
     $actionTwo = $dispatcher->dispatch('emit', '+', $times + \rand(5, 10), 100);
 

src/Wrapper/ContainerWrapper.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\Wrapper;
 
@@ -50,7 +50,7 @@ 
             }
         }
 
-        return function (...$arguments) use ($handler, $resolved) {
+        return function(...$arguments) use ($handler, $resolved) {
             return $handler(...array_replace($arguments, $resolved));
         };
     }

src/HandlerRegistry.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;
 
@@ -49,7 +49,7 @@ 
      */
     public function get(string $signal): callable
     {
-        return $this->handlers[$signal] ?? static function () use ($signal) {
+        return $this->handlers[$signal] ?? static function() use ($signal) {
             throw new Exception\UnknownSignal($signal);
         };
     }

src/DispatcherBuilder.php

Spacing +3 added lines, -3 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;
 
@@ -55,11 +55,11 @@ 
         $registry = new HandlerRegistry;
 
         foreach ($this->handlers as $signal => $handlers) {
-            $handlers = \array_map(function (callable $handler) {
+            $handlers = \array_map(function(callable $handler) {
                 return $this->factory->create($handler);
             }, $handlers);
 
-            $registry->add($signal, static function (...$arguments) use ($handlers) {
+            $registry->add($signal, static function(...$arguments) use ($handlers) {
                 $promises = [];
 
                 foreach ($handlers as $handler) {