AsyncReducer.InstanceImpl | /stream/async/index.ts | rimbu@1.1.0

Rimbu is a TypeScript library focused on immutable, performant, and type-safe collections and other tools.

class AsyncReducer.InstanceImpl

implements [AsyncReducer.Instance]<I, O>

import { AsyncReducer } from "https://deno.land/x/rimbu@1.1.0/stream/async/index.ts";
const { InstanceImpl } = AsyncReducer;

Constructors

new

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

readonly

halted: boolean

readonly

index: number

next: (value: I) => Promise<void>

getOutput(): Promise<O>

onClose(err?: unknown): Promise<void>