abstract class AsyncStreamBase<T>
undocumented
Extended by: AsyncOfStream<T>
, FromResource<T,R>
, FromSource<T>
, AsyncFromStream<T>
Type parameters
Name | Description |
---|---|
T | undocumented |
Methods
[Symbol.asyncIterator]
undocumented
[Symbol.asyncIterator]
Definition
abstract [Symbol.asyncIterator](): AsyncFastIterator<T>;
append
undocumented
append
collect
undocumented
collect
Definition
collect<R>(collectFun:
AsyncCollectFun
<T, R>): AsyncStream<R>;
Type parameters
Name | Description |
---|---|
R |
Parameters
Name | Type | Description |
---|---|---|
collectFun | AsyncCollectFun <T, R> |
concat
undocumented
concat
Definition
concat(...others:
ArrayNonEmpty
<AsyncStreamSource<T>>): any;
Parameters
Name | Type | Description |
---|---|---|
others | ArrayNonEmpty <AsyncStreamSource<T>> |
contains
undocumented
contains
containsSlice
undocumented
containsSlice
countElement
undocumented
countElement
countNotElement
undocumented
countNotElement
distinctPrevious
undocumented
distinctPrevious
drop
undocumented
drop
dropWhile
undocumented
dropWhile
Definition
dropWhile(pred: (value: T, index: number) =>
MaybePromise
<boolean>): AsyncStream<T>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> |
elementAt
undocumented
elementAt
equals
undocumented
equals
every
undocumented
every
Definition
every(pred: (value: T, index: number) =>
MaybePromise
<boolean>): Promise<boolean>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> |
filter
undocumented
filter
Definition
filter(pred: (value: T, index: number, halt: () => void) =>
MaybePromise
<boolean>): AsyncStream<T>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number, halt: () => void) => MaybePromise <boolean> |
filterNot
undocumented
filterNot
Definition
filterNot(pred: (value: T, index: number, halt: () => void) =>
MaybePromise
<boolean>): AsyncStream<T>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number, halt: () => void) => MaybePromise <boolean> |
filterNotPure
undocumented
filterNotPure
Definition
filterNotPure<A extends readonly unknown[]>(pred: (value: T, ...args: A) =>
MaybePromise
<boolean>, ...args: A): AsyncStream<T>;
Type parameters
Name | Constraints | Description |
---|---|---|
A | readonly unknown[] |
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, ...args: A) => MaybePromise <boolean> | |
args | A |
filterPure
undocumented
filterPure
Definition
filterPure<A extends readonly unknown[]>(pred: (value: T, ...args: A) =>
MaybePromise
<boolean>, ...args: A): AsyncStream<T>;
Type parameters
Name | Constraints | Description |
---|---|---|
A | readonly unknown[] |
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, ...args: A) => MaybePromise <boolean> | |
args | A |
find
undocumented
find
Definition
find<O>(pred: (value: T, index: number) =>
MaybePromise
<boolean>, occurrance?: number, otherwise?: AsyncOptLazy<O>): Promise<T
|
O>;
Type parameters
Name | Description |
---|---|
O |
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> | |
occurrance | number | |
otherwise | AsyncOptLazy<O> |
first
undocumented
first
flatMap
undocumented
flatMap
flatZip
undocumented
flatZip
fold
undocumented
fold
Definition
fold<R>(init: AsyncOptLazy<R>, next: (current: R, value: T, index: number, halt: () => void) =>
MaybePromise
<R>): Promise<R>;
Type parameters
Name | Description |
---|---|
R |
Parameters
Name | Type | Description |
---|---|---|
init | AsyncOptLazy<R> | |
next | (current: R, value: T, index: number, halt: () => void) => MaybePromise <R> |
foldStream
undocumented
foldStream
Definition
foldStream<R>(init: AsyncOptLazy<R>, next: (current: R, value: T, index: number, halt: () => void) =>
MaybePromise
<R>): AsyncStream<R>;
Type parameters
Name | Description |
---|---|
R |
Parameters
Name | Type | Description |
---|---|---|
init | AsyncOptLazy<R> | |
next | (current: R, value: T, index: number, halt: () => void) => MaybePromise <R> |
forEach
undocumented
forEach
Definition
forEach(f: (value: T, index: number, halt: () => void) =>
MaybePromise
<void>, state?:
TraverseState
): Promise<void>;
Parameters
Name | Type | Description |
---|---|---|
f | (value: T, index: number, halt: () => void) => MaybePromise <void> | |
state | TraverseState |
forEachPure
undocumented
forEachPure
Definition
forEachPure<A extends readonly unknown[]>(f: (value: T, ...args: A) =>
MaybePromise
<void>, ...args: A): Promise<void>;
Type parameters
Name | Constraints | Description |
---|---|---|
A | readonly unknown[] |
Parameters
Name | Type | Description |
---|---|---|
f | (value: T, ...args: A) => MaybePromise <void> | |
args | A |
indexed
undocumented
indexed
indexOf
undocumented
indexOf
indexWhere
undocumented
indexWhere
Definition
indexWhere(pred: (value: T, index: number) =>
MaybePromise
<boolean>, occurrance?: number): Promise<number
|
undefined>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> | |
occurrance | number |
indicesOf
undocumented
indicesOf
indicesWhere
undocumented
indicesWhere
Definition
indicesWhere(pred: (value: T) =>
MaybePromise
<boolean>): AsyncStream<number>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T) => MaybePromise <boolean> |
intersperse
undocumented
intersperse
join
undocumented
join
Definition
join({ sep, start, end, valueToString, ifEmpty, }?: {
sep?: string
|
undefined;
start?: string
|
undefined;
end?: string
|
undefined;
valueToString?: StringConstructor
|
undefined;
ifEmpty?: undefined;
}): Promise<string>;
Parameters
Name | Type | Description |
---|---|---|
{ sep, start, end, valueToString, ifEmpty, } | { sep?: string | undefined; start?: string | undefined; end?: string | undefined; valueToString?: StringConstructor | undefined; ifEmpty?: undefined; } |
last
undocumented
last
map
undocumented
map
Definition
map<T2>(mapFun: (value: T, index: number) =>
MaybePromise
<T2>): AsyncStream<T2>;
Type parameters
Name | Description |
---|---|
T2 |
Parameters
Name | Type | Description |
---|---|---|
mapFun | (value: T, index: number) => MaybePromise <T2> |
mapPure
undocumented
mapPure
Definition
mapPure<T2, A extends readonly unknown[]>(mapFun: (value: T, ...args: A) =>
MaybePromise
<T2>, ...args: A): AsyncStream<T2>;
Type parameters
Name | Constraints | Description |
---|---|---|
T2 | ||
A | readonly unknown[] |
Parameters
Name | Type | Description |
---|---|---|
mapFun | (value: T, ...args: A) => MaybePromise <T2> | |
args | A |
max
undocumented
max
maxBy
undocumented
maxBy
min
undocumented
min
minBy
undocumented
minBy
mkGroup
undocumented
mkGroup
prepend
undocumented
prepend
reduce
undocumented
reduce
reduceAll
undocumented
reduceAll
reduceAllStream
undocumented
reduceAllStream
reduceStream
undocumented
reduceStream
repeat
undocumented
repeat
single
undocumented
single
some
undocumented
some
Definition
some(pred: (value: T, index: number) =>
MaybePromise
<boolean>): Promise<boolean>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> |
splitOn
undocumented
splitOn
splitWhere
undocumented
splitWhere
Definition
splitWhere(pred: (value: T, index: number) =>
MaybePromise
<boolean>): AsyncStream<T[]>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> |
take
undocumented
take
takeWhile
undocumented
takeWhile
Definition
takeWhile(pred: (value: T, index: number) =>
MaybePromise
<boolean>): AsyncStream<T>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> |
transform
undocumented
transform