Class

cli/src/utils/PushableAsyncIterable.ts:10–10

 * Allows asynchronous pushing of values that can be consumed via for-await-of
 */
export class PushableAsyncIterable<T> implements AsyncIterableIterator<T> {
    private queue: T[] = []
    private waiters: Array<{
        resolve: (value: IteratorResult<T>) => void