@@ -79,7 +79,7 @@ discard block |
||
79 | 79 | public function open() |
80 | 80 | { |
81 | 81 | $command = $this->command->toString(); |
82 | - $this->getOutput()->write("[+] New process with command: " . $command); |
|
82 | + $this->getOutput()->write("[+] New process with command: ".$command); |
|
83 | 83 | |
84 | 84 | // Command options |
85 | 85 | $in = array_values($this->command->getOption('in', array('pipe', 'r'))); |
@@ -114,7 +114,7 @@ discard block |
||
114 | 114 | { |
115 | 115 | if (is_resource($this->process)) { |
116 | 116 | $status = proc_get_status($this->process); |
117 | - return array_key_exists('running', $status) && (bool)$status['running']; |
|
117 | + return array_key_exists('running', $status) && (bool) $status['running']; |
|
118 | 118 | } |
119 | 119 | |
120 | 120 | return false; |
@@ -121,7 +121,7 @@ |
||
121 | 121 | $this->getOutput()->write('[*] No pools found. Exiting.'); |
122 | 122 | exit(1); |
123 | 123 | } else { |
124 | - $this->getOutput()->write("[*] Current PID: " . getmypid()); |
|
124 | + $this->getOutput()->write("[*] Current PID: ".getmypid()); |
|
125 | 125 | |
126 | 126 | foreach ($this->pools as $pool) { |
127 | 127 | $pool->boot(); |
@@ -97,7 +97,7 @@ |
||
97 | 97 | $this->workers[] = $worker; |
98 | 98 | } else { |
99 | 99 | $msg = '$worker must be an instance of WorkerInterface and the same as'; |
100 | - throw new \Exception($msg . get_class($worker)); |
|
100 | + throw new \Exception($msg.get_class($worker)); |
|
101 | 101 | } |
102 | 102 | |
103 | 103 | return $this; |
@@ -43,7 +43,7 @@ discard block |
||
43 | 43 | */ |
44 | 44 | public function write($msg) |
45 | 45 | { |
46 | - print($msg) . PHP_EOL; |
|
46 | + print($msg).PHP_EOL; |
|
47 | 47 | } |
48 | 48 | |
49 | 49 | /** |
@@ -60,7 +60,7 @@ discard block |
||
60 | 60 | $this->buffer = array(); |
61 | 61 | } |
62 | 62 | |
63 | - foreach ((array)$this->buffer as $msg) { |
|
63 | + foreach ((array) $this->buffer as $msg) { |
|
64 | 64 | $this->write($msg); |
65 | 65 | } |
66 | 66 | } |