Signal normal completion; pending and future reads resolve as done.
()
| 25 | |
| 26 | /** Signal normal completion; pending and future reads resolve as done. */ |
| 27 | end(): void { |
| 28 | if (this.ended || this.failed) return |
| 29 | this.ended = true |
| 30 | for (const waiter of this.waiters.splice(0)) { |
| 31 | waiter.resolve({ value: undefined, done: true }) |
| 32 | } |
| 33 | } |
| 34 | |
| 35 | /** Signal failure; pending and future reads reject (after buffered values drain). */ |
| 36 | fail(error: unknown): void { |