| @@ 134-140 (lines=7) @@ | ||
| 131 | /** |
|
| 132 | * @todo duplicated code much? |
|
| 133 | */ |
|
| 134 | if (isset($this->options['read_err'])) { |
|
| 135 | $streamName = $this->options['read_err']; |
|
| 136 | $this->$streamName->on('data', function ($data) use ($streamName) { |
|
| 137 | $this->onData($data, $streamName); |
|
| 138 | }); |
|
| 139 | unset($streamName); |
|
| 140 | } |
|
| 141 | ||
| 142 | if (isset($this->options['read'])) { |
|
| 143 | $streamName = $this->options['read']; |
|
| @@ 142-148 (lines=7) @@ | ||
| 139 | unset($streamName); |
|
| 140 | } |
|
| 141 | ||
| 142 | if (isset($this->options['read'])) { |
|
| 143 | $streamName = $this->options['read']; |
|
| 144 | $this->$streamName->on('data', function ($data) use ($streamName) { |
|
| 145 | $this->onData($data, $streamName); |
|
| 146 | }); |
|
| 147 | unset($streamName); |
|
| 148 | } |
|
| 149 | } |
|
| 150 | ||
| 151 | /** |
|