| @@ 233-239 (lines=7) @@ | ||
| 230 | /** |
|
| 231 | * @todo duplicated code much? |
|
| 232 | */ |
|
| 233 | if (isset($this->options['read_err'])) { |
|
| 234 | $streamName = $this->options['read_err']; |
|
| 235 | $this->$streamName->on('data', function ($data) use ($streamName) { |
|
| 236 | $this->onData($data, $streamName); |
|
| 237 | }); |
|
| 238 | unset($streamName); |
|
| 239 | } |
|
| 240 | ||
| 241 | if (isset($this->options['read'])) { |
|
| 242 | $streamName = $this->options['read']; |
|
| @@ 241-247 (lines=7) @@ | ||
| 238 | unset($streamName); |
|
| 239 | } |
|
| 240 | ||
| 241 | if (isset($this->options['read'])) { |
|
| 242 | $streamName = $this->options['read']; |
|
| 243 | $this->$streamName->on('data', function ($data) use ($streamName) { |
|
| 244 | $this->onData($data, $streamName); |
|
| 245 | }); |
|
| 246 | unset($streamName); |
|
| 247 | } |
|
| 248 | } |
|
| 249 | ||
| 250 | /** |
|