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

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

@@ -26,12 +26,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;
         });
 
@@ -43,9 +43,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);
         });
 
@@ -57,9 +57,9 @@ 
      */
     public function failed(): void
     {
-        $this->async->add(static function () {
+        $this->async->add(static function() {
             throw new \Exception('Test message');
-        })->catch(function ($exception) {
+        })->catch(function($exception) {
             static::assertEquals('Test message', $exception->getMessage());
         });
 

src/Async.php

Spacing +2 added lines, -2 removed lines

@@ -56,9 +56,9 @@
     protected 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 +5 added lines, -5 removed lines

@@ -41,11 +41,11 @@
     protected function find(string $file): ?string
     {
         $paths = array_filter([
-            __DIR__ . '/../../../../'.$file,
-            __DIR__ . '/../../../'.$file,
-            __DIR__ . '/../../'.$file,
-            __DIR__ . '/../'.$file,
-        ], static function (string $path) {
+            __DIR__ . '/../../../../' . $file,
+            __DIR__ . '/../../../' . $file,
+            __DIR__ . '/../../' . $file,
+            __DIR__ . '/../' . $file,
+        ], static function(string $path) {
             return file_exists($path);
         });
         return reset($paths);