(cb)
| 155 | } |
| 156 | |
| 157 | read(cb) { |
| 158 | this._exec(() => { |
| 159 | if (++this.current <= this.limit) { |
| 160 | cb(null, false, this.current); |
| 161 | } else { |
| 162 | cb(null, true, null); |
| 163 | } |
| 164 | }); |
| 165 | } |
| 166 | |
| 167 | close(cb) { |
| 168 | this._exec(() => { |
no test coverage detected