| 120 | * `end()` once; consumers `for await` and terminate cleanly. |
| 121 | */ |
| 122 | class AsyncChunkQueue implements AsyncIterable<string> { |
| 123 | private readonly chunks: Array<string> = [] |
| 124 | private readonly waiters: Array<(r: IteratorResult<string>) => void> = [] |
| 125 | private ended = false |
nothing calls this directly
no outgoing calls
no test coverage detected