(value: T)
| 196 | } |
| 197 | |
| 198 | pushLossless(value: T): boolean { |
| 199 | if (this.closed) { |
| 200 | return false |
| 201 | } |
| 202 | const waiter = this.waiters.shift() |
| 203 | if (waiter) { |
| 204 | waiter(value) |
| 205 | return true |
| 206 | } |
| 207 | this.queue.push(value) |
| 208 | return true |
| 209 | } |
| 210 | |
| 211 | next(): Promise<T | undefined> { |
| 212 | if (this.queue.length > 0) { |
no test coverage detected