@@ 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 | /** |