Skip to main content
Module

x/rimbu/mod.ts>AsyncReducer.InstanceImpl

Rimbu is a TypeScript library focused on immutable, performant, and type-safe collections and other tools.
Latest
class AsyncReducer.InstanceImpl
implements [AsyncReducer.Instance]<I, O>
import { AsyncReducer } from "https://deno.land/x/rimbu@1.2.1/mod.ts";
const { InstanceImpl } = AsyncReducer;

The default AsyncReducer.Impl implementation.

Constructors

new
InstanceImpl(reducer: AsyncReducer.Impl<I, O, S>)

Properties

halt: () => void
readonly
halted: boolean
readonly
index: number
next: (value: I) => Promise<void>

Methods

getOutput(): Promise<O>
initialize(): Promise<void>
onClose(err?: unknown): Promise<void>

Constructors

new
InstanceImpl(reducer: AsyncReducer.Impl<I, O, S>)

Properties

halt: () => void
readonly
halted: boolean
readonly
index: number
next: (value: I) => Promise<void>

Methods

getOutput(): Promise<O>
initialize(): Promise<void>
onClose(err?: unknown): Promise<void>