* Cleanup waiting consumers
()
| 70 | * Cleanup waiting consumers |
| 71 | */ |
| 72 | private cleanup(): void { |
| 73 | // Resolve or reject all waiting consumers |
| 74 | while (this.waiters.length > 0) { |
| 75 | const waiter = this.waiters.shift()! |
| 76 | if (this.error) { |
| 77 | waiter.reject(this.error) |
| 78 | } else { |
| 79 | waiter.resolve({ done: true, value: undefined }) |
| 80 | } |
| 81 | } |
| 82 | } |
| 83 | |
| 84 | /** |
| 85 | * AsyncIterableIterator implementation |
no test coverage detected