@@ -60,7 +60,7 @@ |
||
| 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 | } |
@@ -142,7 +142,7 @@ |
||
| 142 | 142 | $this->add($worker); |
| 143 | 143 | $worker->start(); |
| 144 | 144 | } else { |
| 145 | - throw new \Exception('Maximum number of workers allocated for this pool ('.$this->numberOfWorkers.').'); |
|
| 145 | + throw new \Exception('Maximum number of workers allocated for this pool (' . $this->numberOfWorkers . ').'); |
|
| 146 | 146 | } |
| 147 | 147 | |
| 148 | 148 | return $this; |
@@ -114,7 +114,7 @@ |
||
| 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; |