MuxAsyncIterator | /vendor/https/deno.land/std/async/mod.ts | servest@v1.3.4

class MuxAsyncIterator

implements AsyncIterable<T>

import { MuxAsyncIterator } from "https://deno.land/x/servest@v1.3.4/vendor/https/deno.land/std/async/mod.ts";

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

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

throws: any[]

private

yields: Array<TaggedYieldedValue<T>>

private

callIteratorNext(iterator: AsyncIterator<T>)

add(iterable: AsyncIterable<T>): void

iterate(): AsyncIterableIterator<T>