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';
         };
 

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;
                 }

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) {
+        })->catch(function($exception) {
             static::assertEquals('Test message', $exception->getMessage());
         });
 

src/TaskFactory.php

Spacing +1 added lines, -1 removed lines

@@ -45,7 +45,7 @@
             __DIR__ . '/../../../' . $file,
             __DIR__ . '/../../' . $file,
             __DIR__ . '/../' . $file,
-        ], static function (string $path) {
+        ], static function(string $path) {
             return file_exists($path);
         });