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