graze / parallel-process

src/Pool.php

Spacing +1 added lines, -1 removed lines

@@ -194,7 +194,7 @@
     public function isRunning()
     {
         /** @var Run[] $running */
-        $this->running = array_filter($this->running, function (RunInterface $run) {
+        $this->running = array_filter($this->running, function(RunInterface $run) {
             return $run->isRunning();
         });
 

src/Table.php

Spacing +3 added lines, -3 removed lines

@@ -103,7 +103,7 @@ 
         $spinner = 0;
 
         if ($this->output->getVerbosity() >= OutputInterface::VERBOSITY_VERBOSE) {
-            $onProgress = function ($process, $duration, $last) use ($index, $data, &$spinner) {
+            $onProgress = function($process, $duration, $last) use ($index, $data, &$spinner) {
                 $this->rows[$index] = $this->formatRow(
                     $data,
                     mb_substr(static::SPINNER, $spinner++, 1),
@@ -121,11 +121,11 @@ 
 
         $this->processPool->add(new Run(
             $process,
-            function ($process, $duration, $last) use ($index, $data) {
+            function($process, $duration, $last) use ($index, $data) {
                 $this->rows[$index] = $this->formatRow($data, "<info>✓</info>", $duration, $last);
                 $this->render($index);
             },
-            function ($process, $duration, $last) use ($index, $data) {
+            function($process, $duration, $last) use ($index, $data) {
                 $this->rows[$index] = $this->formatRow($data, "<error>x</error>", $duration, $last);
                 $this->render($index);
                 $this->exceptions[] = new ProcessFailedException($process);

src/Run.php

Spacing +1 added lines, -1 removed lines

@@ -56,7 +56,7 @@
     public function start()
     {
         if (!$this->process->isRunning()) {
-            $this->process->start(function ($type, $data) {
+            $this->process->start(function($type, $data) {
                 $this->last = rtrim($data);
             });
             $this->started = microtime(true);