@@ -71,16 +71,16 @@ |
||
| 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 | }); |
| 78 | 78 | |
| 79 | - $this->connection->on('failed', function () { |
|
| 79 | + $this->connection->on('failed', function() { |
|
| 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 | } |
@@ -68,7 +68,7 @@ |
||
| 68 | 68 | $this->stream = $stream; |
| 69 | 69 | $this->isConnecting = false; |
| 70 | 70 | |
| 71 | - $stream->on('data', function ($chunk) { |
|
| 71 | + $stream->on('data', function($chunk) { |
|
| 72 | 72 | $this->emit('data', [$chunk]); |
| 73 | 73 | }); |
| 74 | 74 | |