package @rimbu/stream/async-custom

undocumented

Interfaces

Name	Description
AsyncStreamConstructors	undocumented

Classes

Name	Description
AsyncAppendIterator	undocumented
AsyncCollectIterator	undocumented
AsyncConcatIterator	undocumented
AsyncDropIterator	undocumented
AsyncDropWhileIterator	undocumented
AsyncFastIteratorBase	undocumented
AsyncFilterIterator	undocumented
AsyncFilterPureIterator	undocumented
AsyncFromStream	undocumented
AsyncIndexedIterator	undocumented
AsyncMapIterator	undocumented
AsyncMapPureIterator	undocumented
AsyncOfIterator	undocumented
AsyncOfStream	undocumented
AsyncPrependIterator	undocumented
AsyncReduceIterator	undocumented
AsyncRepeatIterator	undocumented
AsyncStreamBase	undocumented
AsyncTakeIterator	undocumented
AsyncTransformerFastIterator	undocumented
AsyncTransformerStream	undocumented
AsyncUnfoldIterator	undocumented
AsyncZipAllWithItererator	undocumented
AsyncZipWithIterator	undocumented
FromAsyncIterator	undocumented
FromIterator	undocumented
FromPromise	undocumented
FromResource	undocumented
FromResourceIterator	undocumented
FromSource	undocumented

Functions

asyncStreamSourceToIterator

undocumented

Definition

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

Type parameters

Name	Description
T

Parameters

Name	Type	Description
source	AsyncStreamSource<T>
close	() => MaybePromise<void>

closeIters

undocumented

Definition

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

Parameters

Name	Type	Description
iters	(AsyncIterator<any> |undefined| null)[]

isAsyncFastIterator

undocumented

Definition

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

Type parameters

Name	Description
T

Parameters

Name	Type	Description
iterator	AsyncIterator<T>

isAsyncStream

undocumented

Definition

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

Parameters

Name	Type	Description
obj	any

isEmptyAsyncStreamSourceInstance

undocumented

Definition

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

Parameters

Name	Type	Description
source	AsyncStreamSource<any>

Constants

Name	Description
AsyncStreamConstructorsImpl	undocumented
emptyAsyncFastIterator	undocumented
emptyAsyncStream	undocumented
fixedDoneAsyncIteratorResult	undocumented
fromAsyncStreamSource	undocumented