Apply fixes from StyleCI

src/ErrorProcessOutput.php

@@ -2,8 +2,8 @@
 
 namespace Spatie\Async;
 
-use InvalidArgumentException;
 use Throwable;
+use InvalidArgumentException;
 
 // TODO: Move to separate namespace
 class ErrorProcessOutput extends ProcessOutput
@@ -15,7 +15,7 @@ class ErrorProcessOutput extends ProcessOutput
      */
     public static function create($payload)
     {
-        if (!$payload instanceof Throwable) {
+        if (! $payload instanceof Throwable) {
             throw new InvalidArgumentException('ErrorProcessOutput only accepts Throwables.');
         }
 

src/Pool.php

@@ -27,14 +27,14 @@ public static function create()
         return new static();
     }
 
-    public function concurrency(int $concurrency): Pool
+    public function concurrency(int $concurrency): self
     {
         $this->concurrency = $concurrency;
 
         return $this;
     }
 
-    public function maximumExecutionTime(int $maximumExecutionTime): Pool
+    public function maximumExecutionTime(int $maximumExecutionTime): self
     {
         $this->maximumExecutionTime = $maximumExecutionTime;
 
@@ -124,10 +124,10 @@ public function wait(): void
                     }
 
                     $this->finished($process);
-                } else if ($processStatus == 0) {
+                } elseif ($processStatus == 0) {
                     if ($process->startTime() + $this->maximumExecutionTime < time() || pcntl_wifstopped($status)) {
                         if (! posix_kill($process->pid(), SIGKILL)) {
-                            throw new Exception("Failed to kill {$process->pid()}: " . posix_strerror(posix_get_last_error()));
+                            throw new Exception("Failed to kill {$process->pid()}: ".posix_strerror(posix_get_last_error()));
                         }
 
                         $process->triggerTimeout();
@@ -189,8 +189,6 @@ public function offsetExists($offset)
     public function offsetGet($offset)
     {
         // TODO
-
-        return null;
     }
 
     public function offsetSet($offset, $value)

src/Process.php

@@ -14,7 +14,7 @@ abstract class Process
     protected $errorCallback;
     protected $timeoutCallback;
 
-    public abstract function execute();
+    abstract public function execute();
 
     public function internalId()
     {
@@ -36,21 +36,21 @@ public function startTime()
         return $this->startTime;
     }
 
-    public function then(callable $callback): Process
+    public function then(callable $callback): self
     {
         $this->successCallback = $callback;
 
         return $this;
     }
 
-    public function catch(callable $callback): Process
+    public function catch(callable $callback): self
     {
         $this->errorCallback = $callback;
 
         return $this;
     }
 
-    public function timeout(callable $callback): Process
+    public function timeout(callable $callback): self
     {
         $this->timeoutCallback = $callback;
 
@@ -60,7 +60,7 @@ public function timeout(callable $callback): Process
     public function triggerSuccess($output = null)
     {
         if (! $this->successCallback) {
-            return null;
+            return;
         }
 
         return call_user_func_array($this->successCallback, [$output]);
@@ -69,7 +69,7 @@ public function triggerSuccess($output = null)
     public function triggerError($output = null)
     {
         if (! $this->errorCallback) {
-            return null;
+            return;
         }
 
         return call_user_func_array($this->errorCallback, [$output]);
@@ -78,34 +78,34 @@ public function triggerError($output = null)
     public function triggerTimeout($output = null)
     {
         if (! $this->timeoutCallback) {
-            return null;
+            return;
         }
 
         return call_user_func_array($this->timeoutCallback, [$output]);
     }
 
-    public function setInternalId($internalId): Process
+    public function setInternalId($internalId): self
     {
         $this->internalId = $internalId;
 
         return $this;
     }
 
-    public function setPid($pid): Process
+    public function setPid($pid): self
     {
         $this->pid = $pid;
 
         return $this;
     }
 
-    public function setSocket($socket): Process
+    public function setSocket($socket): self
     {
         $this->socket = $socket;
 
         return $this;
     }
 
-    public function setStartTime($startTime): Process
+    public function setStartTime($startTime): self
     {
         $this->startTime = $startTime;
 

src/helpers.php

@@ -1,13 +1,13 @@
 <?php
 
-use Spatie\Async\CallableProcess;
 use Spatie\Async\Pool;
 use Spatie\Async\Process;
+use Spatie\Async\CallableProcess;
 
 if (! function_exists('async')) {
     function async($process): Process
     {
-        if (!$process instanceof Process) {
+        if (! $process instanceof Process) {
             $process = new CallableProcess($process);
         }