@@ -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 | } |