Skip to main content
Deno 2 is finally here 🎉️
Learn more
Module

std/util/async.ts>MuxAsyncIterator

Deno standard library
denoland/deno
Go to Latest
The Standard Library has been moved to JSR. See the blog post for details.
class MuxAsyncIterator
implements AsyncIterable<T>
import { MuxAsyncIterator } from "https://deno.land/std@v0.35.0/util/async.ts";

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.

Properties

private
iteratorCount: number
private
signal: Deferred<void>
private
yields: Array<TaggedYieldedValue<T>>

Methods

private
callIteratorNext(iterator: AsyncIterableIterator<T>): Promise<void>
add(iterator: AsyncIterableIterator<T>): void
iterate(): AsyncIterableIterator<T>
[Symbol.asyncIterator](): AsyncIterableIterator<T>