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

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

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

Constructors

new
AsyncLiveIterator(maxSize: number)

Properties

close: () => void
halted: boolean
readonly
queue: T[]
submit: (value: T) => void
waitPromise: Promise<void> | undefined
wakeUp: (() => void) | undefined

Methods

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