package @rimbu/stream/async-custom
undocumented
Interfaces
Name | Description |
---|---|
AsyncStreamConstructors | undocumented |
Classes
Functions
asyncStreamSourceToIterator
undocumented
asyncStreamSourceToIterator
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
closeIters
isAsyncFastIterator
undocumented
isAsyncFastIterator
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
isAsyncStream
Definition
export declare function isAsyncStream(obj: any): obj is
AsyncStream
<any>;
Parameters
Name | Type | Description |
---|---|---|
obj | any |
isEmptyAsyncStreamSourceInstance
undocumented
isEmptyAsyncStreamSourceInstance
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 |