Apply fixes from StyleCI

src/ParallelProcess.php

@@ -3,10 +3,9 @@
 namespace Spatie\Async;
 
 use Error;
-use PHPUnit\Runner\Exception;
-use Spatie\Async\Output\SerializableException;
-use Symfony\Component\Process\Process;
 use Throwable;
+use Symfony\Component\Process\Process;
+use Spatie\Async\Output\SerializableException;
 
 class ParallelProcess
 {

src/Pool.php

@@ -74,7 +74,7 @@ public function notify(): void
 
     public function add($process): ParallelProcess
     {
-        if (!$process instanceof ParallelProcess) {
+        if (! $process instanceof ParallelProcess) {
             $process = ParentRuntime::createChildProcess($process);
         }
 
@@ -207,7 +207,7 @@ protected function registerListener(): void
 
                 $process = $this->inProgress[$pid] ?? null;
 
-                if (!$process) {
+                if (! $process) {
                     continue;
                 }
 

src/Runtime/ChildRuntime.php

@@ -4,16 +4,16 @@
     $autoloader = $argv[1];
     $serializedClosure = base64_decode($argv[2]);
 
-    if (!$autoloader) {
+    if (! $autoloader) {
         throw new InvalidArgumentException('No autoloader provided in child process.');
     }
 
-    if (!file_exists($autoloader)) {
+    if (! file_exists($autoloader)) {
         throw new InvalidArgumentException("Could not find autoloader in child process: {$autoloader}");
     }
 
-    if (!$serializedClosure) {
-        throw new InvalidArgumentException("No valid closure was passed to the child process.");
+    if (! $serializedClosure) {
+        throw new InvalidArgumentException('No valid closure was passed to the child process.');
     }
 
     require_once $autoloader;
@@ -22,15 +22,15 @@
 
     $output = call_user_func($closure);
 
-    fputs(STDOUT, base64_encode(serialize($output)));
+    fwrite(STDOUT, base64_encode(serialize($output)));
 
     exit(0);
 } catch (Throwable $e) {
-    require_once __DIR__ . '/../Output/SerializableException.php';
+    require_once __DIR__.'/../Output/SerializableException.php';
 
     $output = new \Spatie\Async\Output\SerializableException($e);
 
-    fputs(STDERR, base64_encode(serialize($output)));
+    fwrite(STDERR, base64_encode(serialize($output)));
 
     exit(1);
 }

src/Runtime/ParentRuntime.php

@@ -2,10 +2,10 @@
 
 namespace Spatie\Async\Runtime;
 
-use Opis\Closure\SerializableClosure;
 use Spatie\Async\ParallelProcess;
-use Symfony\Component\Process\Process;
 use function Opis\Closure\serialize;
+use Opis\Closure\SerializableClosure;
+use Symfony\Component\Process\Process;
 
 class ParentRuntime
 {
@@ -16,21 +16,21 @@ class ParentRuntime
     public static function init()
     {
         $existingAutoloaderFiles = array_filter([
-            __DIR__ . '/../../vendor/autoload.php',
-            __DIR__ . '/../../../vendor/autoload.php',
+            __DIR__.'/../../vendor/autoload.php',
+            __DIR__.'/../../../vendor/autoload.php',
         ], function (string $path) {
             return file_exists($path);
         });
 
         self::$autoloader = reset($existingAutoloaderFiles);
-        self::$childProcessScript = __DIR__ . '/ChildRuntime.php';
+        self::$childProcessScript = __DIR__.'/ChildRuntime.php';
 
         self::$isInitialised = true;
     }
 
     public static function createChildProcess(callable $callable): ParallelProcess
     {
-        if (!self::$isInitialised) {
+        if (! self::$isInitialised) {
             self::init();
         }
 
@@ -40,7 +40,7 @@ public static function createChildProcess(callable $callable): ParallelProcess
             'exec php',
             self::$childProcessScript,
             self::$autoloader,
-            base64_encode(serialize($closure))
+            base64_encode(serialize($closure)),
         ]));
 
         return ParallelProcess::create($process);

tests/ChildRuntimeTest.php

@@ -2,19 +2,19 @@
 
 namespace Spatie\Async\Tests;
 
-use Opis\Closure\SerializableClosure;
 use PHPUnit\Framework\TestCase;
-use Symfony\Component\Process\Process;
 use function Opis\Closure\serialize;
+use Opis\Closure\SerializableClosure;
+use Symfony\Component\Process\Process;
 
 class ChildRuntimeTest extends TestCase
 {
     /** @test */
     public function it_can_run()
     {
-        $bootstrap = __DIR__ . '/../src/Runtime/ChildRuntime.php';
+        $bootstrap = __DIR__.'/../src/Runtime/ChildRuntime.php';
 
-        $autoloader = __DIR__ . '/../vendor/autoload.php';
+        $autoloader = __DIR__.'/../vendor/autoload.php';
 
         $serializedClosure = base64_encode(serialize(new SerializableClosure(function () {
             echo 'child';

tests/PoolTest.php

@@ -183,4 +183,4 @@ public function it_returns_all_the_output_as_an_array()
         $this->assertCount(5, $result);
         $this->assertEquals(10, array_sum($result));
     }
-};
+}