@@ -141,7 +141,7 @@ discard block |
||
| 141 | 141 | $this->isBeingDisconnected = false; |
| 142 | 142 | $this->stream = $stream; |
| 143 | 143 | $this->handleStart(); |
| 144 | - $this->emit('start', [ $this ]); |
|
| 144 | + $this->emit('start', [$this]); |
|
| 145 | 145 | |
| 146 | 146 | return true; |
| 147 | 147 | } |
@@ -170,7 +170,7 @@ discard block |
||
| 170 | 170 | |
| 171 | 171 | $this->reqs = []; |
| 172 | 172 | $this->handleStop(); |
| 173 | - $this->emit('stop', [ $this ]); |
|
| 173 | + $this->emit('stop', [$this]); |
|
| 174 | 174 | |
| 175 | 175 | return true; |
| 176 | 176 | } |
@@ -222,8 +222,8 @@ discard block |
||
| 222 | 222 | { |
| 223 | 223 | if ($this->stream !== null) |
| 224 | 224 | { |
| 225 | - $this->stream->on('data', [ $this, 'handleData' ]); |
|
| 226 | - $this->stream->on('close', [ $this, 'stop' ]); |
|
| 225 | + $this->stream->on('data', [$this, 'handleData']); |
|
| 226 | + $this->stream->on('close', [$this, 'stop']); |
|
| 227 | 227 | } |
| 228 | 228 | } |
| 229 | 229 | |
@@ -234,8 +234,8 @@ discard block |
||
| 234 | 234 | { |
| 235 | 235 | if ($this->stream !== null) |
| 236 | 236 | { |
| 237 | - $this->stream->removeListener('data', [ $this, 'handleData' ]); |
|
| 238 | - $this->stream->removeListener('close', [ $this, 'stop' ]); |
|
| 237 | + $this->stream->removeListener('data', [$this, 'handleData']); |
|
| 238 | + $this->stream->removeListener('close', [$this, 'stop']); |
|
| 239 | 239 | } |
| 240 | 240 | } |
| 241 | 241 | |
@@ -252,7 +252,7 @@ discard block |
||
| 252 | 252 | } |
| 253 | 253 | catch (ParserException $error) |
| 254 | 254 | { |
| 255 | - $this->emit('error', [ $this, $error ]); |
|
| 255 | + $this->emit('error', [$this, $error]); |
|
| 256 | 256 | $this->stop(); |
| 257 | 257 | return; |
| 258 | 258 | } |
@@ -265,7 +265,7 @@ discard block |
||
| 265 | 265 | } |
| 266 | 266 | catch (UnderflowException $error) |
| 267 | 267 | { |
| 268 | - $this->emit('error', [ $this, $error ]); |
|
| 268 | + $this->emit('error', [$this, $error]); |
|
| 269 | 269 | $this->stop(); |
| 270 | 270 | return; |
| 271 | 271 | } |