hhxsv5 / laravel-s

src/Swoole/Timer/TimerTrait.php

Spacing +8 added lines, -8 removed lines

@@ -16,8 +16,8 @@ 
             return false;
         }
 
-        $callback = function (Process $process) use ($swoole, $config, $laravelConfig) {
-            $pidfile = dirname($swoole->setting['pid_file']) . '/' . $this->timerPidFile;
+        $callback = function(Process $process) use ($swoole, $config, $laravelConfig) {
+            $pidfile = dirname($swoole->setting['pid_file']).'/'.$this->timerPidFile;
             file_put_contents($pidfile, $process->pid);
             $this->setProcessTitle(sprintf('%s laravels: timer process', $config['process_prefix']));
             $this->initLaravel($laravelConfig, $swoole);
@@ -39,9 +39,9 @@ 
                 if (empty($job->interval())) {
                     throw new \InvalidArgumentException(sprintf('The interval of %s cannot be empty', get_class($job)));
                 }
-                $runJob = function () use ($job) {
-                    $runCallback = function () use ($job) {
-                        $this->callWithCatchException(function () use ($job) {
+                $runJob = function() use ($job) {
+                    $runCallback = function() use ($job) {
+                        $this->callWithCatchException(function() use ($job) {
                             $job->run();
                         });
                     };
@@ -57,17 +57,17 @@ 
             }
 
             // This timer is used to ensure that timer process does not exit when all timers are cleared.
-            $timerIds[] = Timer::tick(3600 * 12 * 1000, function () {
+            $timerIds[] = Timer::tick(3600 * 12 * 1000, function() {
                 // Do nothing.
             });
 
-            Process::signal(SIGUSR1, function ($signo) use ($config, $timerIds, $process) {
+            Process::signal(SIGUSR1, function($signo) use ($config, $timerIds, $process) {
                 foreach ($timerIds as $timerId) {
                     if (Timer::exists($timerId)) {
                         Timer::clear($timerId);
                     }
                 }
-                Timer::after($config['max_wait_time'] * 1000, function () use ($process) {
+                Timer::after($config['max_wait_time'] * 1000, function() use ($process) {
                     $process->exit(0);
                 });
             });