@@ -34,21 +34,21 @@ discard block |
||
34 | 34 | |
35 | 35 | $registeredWorkers = app()->get('worker'); |
36 | 36 | |
37 | - if(isset($registeredWorkers[$worker])){ |
|
37 | + if (isset($registeredWorkers[$worker])) { |
|
38 | 38 | |
39 | - if(!is_callable($registeredWorkers[$worker]) && Utils::isNamespaceExists($registeredWorkers[$worker])) { |
|
40 | - $resolve = app()->resolve($registeredWorkers[$worker],['data'=>(array)$this->argument['data']]); |
|
39 | + if (!is_callable($registeredWorkers[$worker]) && Utils::isNamespaceExists($registeredWorkers[$worker])) { |
|
40 | + $resolve = app()->resolve($registeredWorkers[$worker], ['data'=>(array)$this->argument['data']]); |
|
41 | 41 | } |
42 | 42 | |
43 | - while(true){ |
|
43 | + while (true) { |
|
44 | 44 | |
45 | - if(isset($resolve)){ |
|
45 | + if (isset($resolve)) { |
|
46 | 46 | $result = $resolve->handle(); |
47 | 47 | echo $this->classical($worker.' worker called : '.$result); |
48 | 48 | sleep($resolve->getSleep()); |
49 | 49 | } |
50 | 50 | |
51 | - if(is_callable($registeredWorkers[$worker])){ |
|
51 | + if (is_callable($registeredWorkers[$worker])) { |
|
52 | 52 | echo $this->classical($registeredWorkers[$worker](1)); |
53 | 53 | sleep(10); |
54 | 54 | } |
@@ -65,7 +65,7 @@ discard block |
||
65 | 65 | */ |
66 | 66 | public function create() |
67 | 67 | { |
68 | - if(!file_exists(app()->path()->workers())){ |
|
68 | + if (!file_exists(app()->path()->workers())) { |
|
69 | 69 | $this->directory['worker'] = app()->path()->workers(); |
70 | 70 | $this->file->makeDirectory($this); |
71 | 71 | } |
@@ -74,7 +74,7 @@ discard block |
||
74 | 74 | $this->argument['workerClass'] = ucfirst($this->argument['worker']).''; |
75 | 75 | $this->argument['projectName'] = strtolower($this->projectName()); |
76 | 76 | |
77 | - $this->touch['worker/worker']= app()->path()->workers().'/'.$this->argument['worker'].'.php'; |
|
77 | + $this->touch['worker/worker'] = app()->path()->workers().'/'.$this->argument['worker'].'.php'; |
|
78 | 78 | |
79 | 79 | |
80 | 80 | $this->file->touch($this); |