Skip to main content
Using Deno in production at your company? Earn free Deno merch.
Give us feedback
Module

x/rimbu/stream/async-custom/async-fast-iterator-base.ts>AsyncFlatMapIterator

Rimbu is a TypeScript library focused on immutable, performant, and type-safe collections and other tools.
Go to Latest
class AsyncFlatMapIterator
import { AsyncFlatMapIterator } from "https://deno.land/x/rimbu@0.14.1/stream/async-custom/async-fast-iterator-base.ts";

Constructors

new
AsyncFlatMapIterator(
source: AsyncStream<T>,
flatMapFun: (
value: T,
index: number,
halt: () => void,
) => AsyncStreamSource<T2>
,
asyncStreamSourceHelpers: AsyncStreamSourceHelpers,
)

Properties

currentIterator: null | AsyncFastIterator<T2>
done: boolean
iterator: AsyncFastIterator<T>
readonly
state

Methods

fastNext<O>(otherwise?: AsyncOptLazy<O>): Promise<T2 | O>