dazzle-php /
redis
| @@ 215-222 (lines=8) @@ | ||
| 212 | /** |
|
| 213 | * @internal |
|
| 214 | */ |
|
| 215 | protected function handleStart() |
|
| 216 | { |
|
| 217 | if ($this->stream !== null) |
|
| 218 | { |
|
| 219 | $this->stream->on('data', [ $this, 'handleData' ]); |
|
| 220 | $this->stream->on('close', [ $this, 'stop' ]); |
|
| 221 | } |
|
| 222 | } |
|
| 223 | ||
| 224 | /** |
|
| 225 | * @internal |
|
| @@ 227-234 (lines=8) @@ | ||
| 224 | /** |
|
| 225 | * @internal |
|
| 226 | */ |
|
| 227 | protected function handleStop() |
|
| 228 | { |
|
| 229 | if ($this->stream !== null) |
|
| 230 | { |
|
| 231 | $this->stream->removeListener('data', [ $this, 'handleData' ]); |
|
| 232 | $this->stream->removeListener('close', [ $this, 'stop' ]); |
|
| 233 | } |
|
| 234 | } |
|
| 235 | ||
| 236 | /** |
|
| 237 | * @internal |
|
