AsyncReduceAllIterator | /stream/async-custom/index.ts | rimbu@0.13.1

Module

x/rimbu/stream/async-custom/index.ts>AsyncReduceAllIterator

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

rimbu-org/rimbu

Go to Latest

index.ts (default module)

AsyncAppendIterator

AsyncCollectIterator

AsyncConcatIterator

AsyncDistinctPreviousIterator

AsyncDropIterator

AsyncDropWhileIterator

AsyncFastIteratorBase

AsyncFilterIterator

AsyncFilterPureIterator

AsyncIndicesOfIterator

AsyncIndicesWhereIterator

AsyncIntersperseIterator

AsyncReduceAllIterator

AsyncReduceIterator

AsyncRepeatIterator

AsyncSplitOnIterator

AsyncSplitWhereIterator

AsyncStreamBase

AsyncTakeIterator

AsyncTakeWhileIterator

AsyncUnfoldIterator

AsyncWindowIterator

AsyncZipAllWithItererator

AsyncStreamConstructors

AsyncStreamConstructorsImpl

emptyAsyncFastIterator

emptyAsyncStream

fixedDoneAsyncIteratorResult

fromAsyncStreamSource

asyncStreamSourceToIterator

closeIters

isAsyncFastIterator

isAsyncStream

isEmptyAsyncStreamSourceInstance

async-fast-iterator-base.ts

AsyncAppendIterator

AsyncCollectIterator

AsyncConcatIterator

AsyncDistinctPreviousIterator

AsyncDropIterator

AsyncDropWhileIterator

AsyncFastIteratorBase

AsyncFilterIterator

AsyncFilterPureIterator

AsyncFlatMapIterator

AsyncFoldIterator

AsyncIndexedIterator

AsyncIndicesOfIterator

AsyncIndicesWhereIterator

AsyncIntersperseIterator

AsyncReduceAllIterator

AsyncReduceIterator

AsyncRepeatIterator

AsyncSplitOnIterator

AsyncSplitWhereIterator

AsyncTakeIterator

AsyncTakeWhileIterator

AsyncUnfoldIterator

AsyncWindowIterator

AsyncZipAllWithItererator

emptyAsyncFastIterator

fixedDoneAsyncIteratorResult

isAsyncFastIterator

async-stream-custom.ts

AsyncStreamConstructorsImpl

emptyAsyncStream

fromAsyncStreamSource

asyncStreamSourceToIterator

isAsyncStream

isEmptyAsyncStreamSourceInstance

constructors.ts

AsyncStreamConstructors

utils.ts

closeIters

class AsyncReduceAllIterator

extends AsyncFastIteratorBase<R>

Re-export

import { AsyncReduceAllIterator } from "https://deno.land/x/rimbu@0.13.1/stream/async-custom/index.ts";

Constructors

new

AsyncReduceAllIterator(source: AsyncFastIterator<I>, reducers: AsyncReducer<I, any>[])

Type Parameters

Properties

err: any

index: number

isDone: boolean

readonly

reducersToClose: Set<AsyncReducer<any>>

optional

state: unknown[]

Methods

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