resquebundle / resque

Command/StartWorkerCommand.php

Spacing +1 added lines, -1 removed lines

@@ -132,7 +132,7 @@
 
         // if foreground, we redirect output
         if ($input->getOption('foreground')) {
-            $process->run(function ($type, $buffer) use ($output) {
+            $process->run(function($type, $buffer) use ($output) {
                 $output->write($buffer);
             });
         } // else we recompose and display the worker id

Command/StartScheduledWorkerCommand.php

Spacing +1 added lines, -1 removed lines

@@ -106,7 +106,7 @@
         $output->writeln(\sprintf('Starting worker <info>%s</info>', $process->getCommandLine()));
 
         if ($input->getOption('foreground')) {
-            $process->run(function ($type, $buffer) use ($output) {
+            $process->run(function($type, $buffer) use ($output) {
                 $output->write($buffer);
             });
         } // else we recompose and display the worker id

Resque.php

Spacing +1 added lines, -1 removed lines

@@ -251,7 +251,7 @@
      */
     public function getRunningWorkers()
     {
-        return array_filter($this->getWorkers(), function (Worker $worker) {
+        return array_filter($this->getWorkers(), function(Worker $worker) {
             return $worker->getCurrentJob() !== null;
         });
     }