()
| 8677 | } |
| 8678 | |
| 8679 | _destroy() { |
| 8680 | this.isAlive = false; |
| 8681 | this._resetBackpressure(); |
| 8682 | this.stream.removeConsumer(this.id); |
| 8683 | } |
| 8684 | |
| 8685 | async _waitForNextItem(timeout) { |
| 8686 | return new Promise((resolve, reject) => { |
no test coverage detected