@@ -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 |
@@ -74,16 +74,16 @@ |
||
74 | 74 | |
75 | 75 | protected function setConnectionHandlers() |
76 | 76 | { |
77 | - $this->connection->on('data', function ($chunk) { |
|
77 | + $this->connection->on('data', function($chunk) { |
|
78 | 78 | $parsed = $this->parser->parseRawResponse($chunk); |
79 | 79 | $this->resolveRequests($parsed); |
80 | 80 | }); |
81 | 81 | |
82 | - $this->connection->on('failed', function () { |
|
82 | + $this->connection->on('failed', function() { |
|
83 | 83 | $this->pool->rejectAllWith(new ConnectionClosedException()); |
84 | 84 | }); |
85 | 85 | |
86 | - $this->connection->on('close', function () { |
|
86 | + $this->connection->on('close', function() { |
|
87 | 87 | if (!$this->isEnding) { |
88 | 88 | $this->emit('error', [new ConnectionClosedException()]); |
89 | 89 | } |