(bytes)
| 67 | } |
| 68 | |
| 69 | push(bytes) { |
| 70 | if (this._closed || this._err) return; |
| 71 | if (this._pending) { |
| 72 | const r = this._pending; |
| 73 | this._pending = null; |
| 74 | r({ value: bytes, done: false }); |
| 75 | } else this._q.push(bytes); |
| 76 | } |
| 77 | |
| 78 | close() { |
| 79 | if (this._closed || this._err) return; |
no outgoing calls