@@ -71,7 +71,7 @@ discard block |
||
| 71 | 71 | |
| 72 | 72 | protected function setConnectionHandlers() |
| 73 | 73 | { |
| 74 | - $this->connection->on('data', function ($chunk) { |
|
| 74 | + $this->connection->on('data', function($chunk) { |
|
| 75 | 75 | $parsed = $this->parser->parseRawResponse($chunk); |
| 76 | 76 | $this->resolveRequests($parsed); |
| 77 | 77 | }); |
@@ -80,7 +80,7 @@ discard block |
||
| 80 | 80 | $this->rejectPendingRequestsWith(new ConnectionClosedException()); |
| 81 | 81 | }); |
| 82 | 82 | |
| 83 | - $this->connection->on('close', function () { |
|
| 83 | + $this->connection->on('close', function() { |
|
| 84 | 84 | if (!$this->isEnding) { |
| 85 | 85 | $this->emit('error', [new ConnectionClosedException()]); |
| 86 | 86 | } |
@@ -96,7 +96,7 @@ discard block |
||
| 96 | 96 | { |
| 97 | 97 | $request = new Request($name); |
| 98 | 98 | |
| 99 | - if($this->isEnding) { |
|
| 99 | + if ($this->isEnding) { |
|
| 100 | 100 | $request->reject(new ConnectionClosedException()); |
| 101 | 101 | } else { |
| 102 | 102 | try { |
@@ -173,7 +173,7 @@ discard block |
||
| 173 | 173 | */ |
| 174 | 174 | protected function rejectPendingRequestsWith(Exception $exception) |
| 175 | 175 | { |
| 176 | - while($this->hasPendingRequests()) { |
|
| 176 | + while ($this->hasPendingRequests()) { |
|
| 177 | 177 | $request = array_shift($this->requests); |
| 178 | 178 | /* @var $request Request */ |
| 179 | 179 | $request->reject($exception); |