Skip to main content

package @rimbu/stream/async-custom

undocumented

Interfaces

NameDescription
AsyncStreamConstructorsundocumented

Classes

NameDescription
AsyncAppendIteratorundocumented
AsyncCollectIteratorundocumented
AsyncConcatIteratorundocumented
AsyncDistinctPreviousIteratorundocumented
AsyncDropIteratorundocumented
AsyncDropWhileIteratorundocumented
AsyncFastIteratorBaseundocumented
AsyncFilterIteratorundocumented
AsyncFilterPureIteratorundocumented
AsyncFlatMapIteratorundocumented
AsyncFoldIteratorundocumented
AsyncFromStreamundocumented
AsyncIndexedIteratorundocumented
AsyncIndicesOfIteratorundocumented
AsyncIndicesWhereIteratorundocumented
AsyncIntersperseIteratorundocumented
AsyncLiveIteratorundocumented
AsyncMapIteratorundocumented
AsyncMapPureIteratorundocumented
AsyncOfIteratorundocumented
AsyncOfStreamundocumented
AsyncPrependIteratorundocumented
AsyncReduceAllIteratorundocumented
AsyncReduceIteratorundocumented
AsyncRepeatIteratorundocumented
AsyncSplitOnIteratorundocumented
AsyncSplitWhereIteratorundocumented
AsyncStreamBaseundocumented
AsyncTakeIteratorundocumented
AsyncTakeWhileIteratorundocumented
AsyncUnfoldIteratorundocumented
AsyncWindowIteratorundocumented
AsyncZipAllWithItereratorundocumented
AsyncZipWithIteratorundocumented
FromAsyncIteratorundocumented
FromIteratorundocumented
FromPromiseundocumented
FromResourceundocumented
FromResourceIteratorundocumented
FromSourceundocumented

Functions

asyncStreamSourceToIterator

undocumented

Definition

export declare function asyncStreamSourceToIterator<T>(source: AsyncStreamSource<T>, close?: () => MaybePromise<void>): AsyncFastIterator<T>;

Type parameters
NameDescription
T

Parameters

NameTypeDescription
sourceAsyncStreamSource<T>
close() => MaybePromise<void>

closeIters

undocumented

Definition

export declare function closeIters(...iters: (AsyncIterator<any> |undefined| null)[]): Promise<void>;

Parameters

NameTypeDescription
iters(AsyncIterator<any> |undefined| null)[]

isAsyncFastIterator

undocumented

Definition

export declare function isAsyncFastIterator<T>(iterator: AsyncIterator<T>): iterator is AsyncFastIterator<T>;

Type parameters
NameDescription
T

Parameters

NameTypeDescription
iteratorAsyncIterator<T>

isAsyncStream

undocumented

Definition

export declare function isAsyncStream(obj: any): obj is AsyncStream<any>;

Parameters

NameTypeDescription
objany

isEmptyAsyncStreamSourceInstance

undocumented

Definition

export declare function isEmptyAsyncStreamSourceInstance(source: AsyncStreamSource<any>): boolean;

Parameters

NameTypeDescription
sourceAsyncStreamSource<any>

Constants

NameDescription
AsyncStreamConstructorsImplundocumented
emptyAsyncFastIteratorundocumented
emptyAsyncStreamundocumented
fixedDoneAsyncIteratorResultundocumented
fromAsyncStreamSourceundocumented