teodoroleckie / async

src/Task.php

Spacing +1 added lines, -1 removed lines

@@ -71,7 +71,7 @@
         return $this;
     }
 
-    public function catch(callable $callback): self
+    public function catch (callable $callback): self
     {
         $this->error[] = $callback;
 

src/TaskInterface.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
      * @param callable $callback
      * @return mixed
      */
-    public function catch(callable $callback): self;
+    public function catch (callable $callback): self;
 
     /**
      * @return $this

src/Async.php

Spacing +2 added lines, -2 removed lines

@@ -57,9 +57,9 @@
     private function listener(): void
     {
         pcntl_async_signals(true);
-        pcntl_signal(SIGCHLD, function ($signo, $status) {
+        pcntl_signal(SIGCHLD, function($signo, $status) {
             while (true) {
-                $pid = pcntl_waitpid(-1, $processState, WNOHANG | WUNTRACED);
+                $pid = pcntl_waitpid(-1, $processState, WNOHANG|WUNTRACED);
                 if ($pid <= 0) {
                     break;
                 }

src/TaskFactory.php

Spacing +2 added lines, -2 removed lines

@@ -47,7 +47,7 @@ 
                 __DIR__ . '/../bin/child',
                 __DIR__ . '/bin/child',
 
-            ], static function (string $path) {
+            ], static function(string $path) {
                 return file_exists($path);
             });
             $this->script = reset($paths);
@@ -67,7 +67,7 @@ 
                 __DIR__ . '/../../../vendor/autoload.php',
                 __DIR__ . '/../../vendor/autoload.php',
                 __DIR__ . '/../vendor/autoload.php',
-            ], static function (string $path) {
+            ], static function(string $path) {
                 return file_exists($path);
             });
             $this->autoloader = reset($paths);

tests/ChildTest.php

Spacing +3 added lines, -3 removed lines

@@ -35,7 +35,7 @@ 
      */
     public function handle(): void
     {
-        $closure = function () {
+        $closure = function() {
             return 33;
         };
 
@@ -55,7 +55,7 @@ 
      */
     public function handleException(): void
     {
-        $closure = function () {
+        $closure = function() {
             throw new Exception('Test message');
         };
 
@@ -75,7 +75,7 @@ 
      */
     public function write(): void
     {
-        $closure = function () {
+        $closure = function() {
             return 'Same return value';
         };
 

tests/AsyncTest.php

Spacing +6 added lines, -6 removed lines

@@ -27,12 +27,12 @@ 
      */
     public function add(): void
     {
-        $this->async->add(static function () {
+        $this->async->add(static function() {
             usleep(8000);
 
             return 555;
         });
-        $this->async->add(static function () {
+        $this->async->add(static function() {
             return 2;
         });
 
@@ -44,9 +44,9 @@ 
      */
     public function then(): void
     {
-        $this->async->add(static function () {
+        $this->async->add(static function() {
             return 555;
-        })->then(static function (int $value) {
+        })->then(static function(int $value) {
             static::assertEquals(555, $value);
         });
 
@@ -58,9 +58,9 @@ 
      */
     public function failed(): void
     {
-        $this->async->add(static function () {
+        $this->async->add(static function() {
             throw new Exception('Test message');
-        })->catch(function (Exception $exception) {
+        })->catch(function(Exception $exception) {
             static::assertEquals('Test message', $exception->getMessage());
         });