@@ -149,7 +149,7 @@ discard block |
||
149 | 149 | $this->isBeingDisconnected = false; |
150 | 150 | $this->stream = $stream; |
151 | 151 | $this->handleStart(); |
152 | - $this->emit('start', [ $this ]); |
|
152 | + $this->emit('start', [$this]); |
|
153 | 153 | |
154 | 154 | return Promise::doResolve($this); |
155 | 155 | } |
@@ -178,7 +178,7 @@ discard block |
||
178 | 178 | |
179 | 179 | $this->reqs = []; |
180 | 180 | $this->handleStop(); |
181 | - $this->emit('stop', [ $this ]); |
|
181 | + $this->emit('stop', [$this]); |
|
182 | 182 | |
183 | 183 | if ($this->endPromise !== null) |
184 | 184 | { |
@@ -243,8 +243,8 @@ discard block |
||
243 | 243 | { |
244 | 244 | if ($this->stream !== null) |
245 | 245 | { |
246 | - $this->stream->on('data', [ $this, 'handleData' ]); |
|
247 | - $this->stream->on('close', [ $this, 'stop' ]); |
|
246 | + $this->stream->on('data', [$this, 'handleData']); |
|
247 | + $this->stream->on('close', [$this, 'stop']); |
|
248 | 248 | } |
249 | 249 | } |
250 | 250 | |
@@ -255,8 +255,8 @@ discard block |
||
255 | 255 | { |
256 | 256 | if ($this->stream !== null) |
257 | 257 | { |
258 | - $this->stream->removeListener('data', [ $this, 'handleData' ]); |
|
259 | - $this->stream->removeListener('close', [ $this, 'stop' ]); |
|
258 | + $this->stream->removeListener('data', [$this, 'handleData']); |
|
259 | + $this->stream->removeListener('close', [$this, 'stop']); |
|
260 | 260 | } |
261 | 261 | } |
262 | 262 | |
@@ -273,7 +273,7 @@ discard block |
||
273 | 273 | } |
274 | 274 | catch (ParserException $error) |
275 | 275 | { |
276 | - $this->emit('error', [ $this, $error ]); |
|
276 | + $this->emit('error', [$this, $error]); |
|
277 | 277 | $this->stop(); |
278 | 278 | return; |
279 | 279 | } |
@@ -286,7 +286,7 @@ discard block |
||
286 | 286 | } |
287 | 287 | catch (UnderflowException $error) |
288 | 288 | { |
289 | - $this->emit('error', [ $this, $error ]); |
|
289 | + $this->emit('error', [$this, $error]); |
|
290 | 290 | $this->stop(); |
291 | 291 | return; |
292 | 292 | } |