DenoAsync.MuxAsyncIterator | /deps.ts | cordeno@v0.3.5

class DenoAsync.MuxAsyncIterator

implements AsyncIterable<T>

import { DenoAsync } from "https://deno.land/x/cordeno@v0.3.5/deps.ts";
const { MuxAsyncIterator } = DenoAsync;

The MuxAsyncIterator class multiplexes multiple async iterators into a single stream. It currently makes a few assumptions:

The iterators do not throw.
The final result (the value returned and not yielded from the iterator) does not matter; if there is any, it is discarded.

Type Parameters

private

iteratorCount: number

private

signal: Deferred<void>

private

yields: Array<TaggedYieldedValue<T>>

private

callIteratorNext(iterator: AsyncIterableIterator<T>): Promise<void>

add(iterator: AsyncIterableIterator<T>): void

iterate(): AsyncIterableIterator<T>

[Symbol.asyncIterator](): AsyncIterableIterator<T>