| @@ -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(); | 
| @@ -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 | } | 
| @@ -88,7 +88,7 @@ discard block | ||
| 88 | 88 |          try { | 
| 89 | 89 | $this->setWorkerInstance($worker); | 
| 90 | 90 |          } catch (\Exception $e) { | 
| 91 | -            $this->getOutput()->write('[x] Unable to set worker instance: ' . $e->getMessage()); | |
| 91 | +            $this->getOutput()->write('[x] Unable to set worker instance: '.$e->getMessage()); | |
| 92 | 92 | } | 
| 93 | 93 | |
| 94 | 94 | $cmd1 = $worker->getProcess()->getCommand()->getCmd(); | 
| @@ -98,7 +98,7 @@ discard block | ||
| 98 | 98 | $this->workers[] = $worker; | 
| 99 | 99 |          } else { | 
| 100 | 100 | $msg = '$worker must be an instance of WorkerInterface and the same as'; | 
| 101 | - throw new \Exception($msg . get_class($worker)); | |
| 101 | + throw new \Exception($msg.get_class($worker)); | |
| 102 | 102 | } | 
| 103 | 103 | |
| 104 | 104 | return $this; |