abstract class AsyncStreamBase<T>
undocumented
Implements: AsyncStream<T>
Extended by: AsyncOfStream<T>
, FromResource<T,R>
, AsyncTransformerStream<T,R>
, FromSource<T>
, AsyncFromStream<T>
Type parameters
Name | Description |
---|---|
T | undocumented |
Methods
[Symbol.asyncIterator]
undocumented
[Symbol.asyncIterator]
append
undocumented
append
Definition
append(value: AsyncOptLazy<T>):
AsyncStream.NonEmpty
<T>;
Parameters
Name | Type | Description |
---|---|---|
value | AsyncOptLazy<T> |
Overrides
asNormal
undocumented
asNormal
Definition
asNormal():
AsyncStream
<T>;
assumeNonEmpty
undocumented
assumeNonEmpty
asyncStream
undocumented
asyncStream
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> |
Overrides
concat
undocumented
concat
Definition
concat(...others:
ArrayNonEmpty
<
AsyncStreamSource
<T>>): any;
Parameters
Name | Type | Description |
---|---|---|
others | ArrayNonEmpty < AsyncStreamSource <T>> |
Overrides
contains
undocumented
contains
containsSlice
undocumented
containsSlice
Definition
containsSlice(source:
AsyncStreamSource.NonEmpty
<T>, options?: {
eq?: Eq<T>;
amount?: number;
}): Promise<boolean>;
Parameters
Name | Type | Description |
---|---|---|
source | AsyncStreamSource.NonEmpty <T> | |
options | { eq?: Eq<T>; amount?: number; } |
Overrides
count
undocumented
count
countElement
undocumented
countElement
distinctPrevious
undocumented
distinctPrevious
Definition
distinctPrevious(options?: {
eq?: Eq<T>
|
undefined;
negate?: boolean
|
undefined;
}):
AsyncStream
<T>;
Parameters
Name | Type | Description |
---|---|---|
options | { eq?: Eq<T> | undefined; negate?: boolean | undefined; } |
Overrides
drop
undocumented
drop
Definition
drop(amount: number):
AsyncStream
<T>;
Parameters
Name | Type | Description |
---|---|---|
amount | number |
Overrides
dropWhile
undocumented
dropWhile
Definition
dropWhile(pred: (value: T, index: number) =>
MaybePromise
<boolean>, options?: {
negate?: boolean;
}):
AsyncStream
<T>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> | |
options | { negate?: boolean; } |
Overrides
elementAt
undocumented
elementAt
equals
undocumented
equals
Definition
equals(other:
AsyncStreamSource
<T>, options?: {
eq?: Eq<T>;
negate?: boolean;
}): Promise<boolean>;
Parameters
Name | Type | Description |
---|---|---|
other | AsyncStreamSource <T> | |
options | { eq?: Eq<T>; negate?: boolean; } |
Overrides
every
undocumented
every
Definition
every(pred: (value: T, index: number) =>
MaybePromise
<boolean>, options?: {
negate?: boolean;
}): Promise<boolean>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> | |
options | { negate?: boolean; } |
Overrides
filter
undocumented
filter
Definition
filter(pred: (value: T, index: number, halt: () => void) =>
MaybePromise
<boolean>, options?: {
negate?: boolean
|
undefined;
}): any;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number, halt: () => void) => MaybePromise <boolean> | |
options | { negate?: boolean | undefined; } |
Overrides
filterPure
undocumented
filterPure
Definition
filterPure<A extends readonly unknown[]>(options: {
pred: (value: T, ...args: A) =>
MaybePromise
<boolean>;
negate?: boolean
|
undefined;
}, ...args: A): any;
Type parameters
Name | Constraints | Description |
---|---|---|
A | readonly unknown[] |
Parameters
Name | Type | Description |
---|---|---|
options | { pred: (value: T, ...args: A) => MaybePromise <boolean>; negate?: boolean | undefined; } | |
args | A |
Overrides
find
undocumented
find
Definition
find<O>(pred: (value: T, index: number) =>
MaybePromise
<boolean>, options?: {
occurrance?: number
|
undefined;
negate?: boolean
|
undefined;
otherwise?: AsyncOptLazy<O>;
}): Promise<T
|
O>;
Type parameters
Name | Description |
---|---|
O |
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> | |
options | { occurrance?: number | undefined; negate?: boolean | undefined; otherwise?: AsyncOptLazy<O>; } |
Overrides
first
undocumented
first
flatMap
undocumented
flatMap
Definition
flatMap<T2>(flatMapFun: (value: T, index: number, halt: () => void) =>
AsyncStreamSource
<T2>):
AsyncStream
<T2>;
Type parameters
Name | Description |
---|---|
T2 |
Parameters
Name | Type | Description |
---|---|---|
flatMapFun | (value: T, index: number, halt: () => void) => AsyncStreamSource <T2> |
Overrides
flatZip
undocumented
flatZip
Definition
flatZip<T2>(flatMapFun: (value: T, index: number, halt: () => void) =>
AsyncStreamSource
<T2>):
AsyncStream
<[T, T2]>;
Type parameters
Name | Description |
---|---|
T2 |
Parameters
Name | Type | Description |
---|---|---|
flatMapFun | (value: T, index: number, halt: () => void) => AsyncStreamSource <T2> |
Overrides
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> |
Overrides
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> |
Overrides
forEach
undocumented
forEach
Definition
forEach(f: (value: T, index: number, halt: () => void) =>
MaybePromise
<void>, options?: {
state?:
TraverseState
;
}): Promise<void>;
Parameters
Name | Type | Description |
---|---|---|
f | (value: T, index: number, halt: () => void) => MaybePromise <void> | |
options | { state?: TraverseState ; } |
Overrides
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 |
Overrides
groupBy
undocumented
groupBy
Definition
groupBy<K, R>(valueToKey: (value: T, index: number) =>
MaybePromise
<K>, options?: {
collector?:
AsyncReducer.Accept
<readonly [K, T], R>
|
undefined;
}): Promise<R>;
Type parameters
Name | Description |
---|---|
K | |
R |
Parameters
Name | Type | Description |
---|---|---|
valueToKey | (value: T, index: number) => MaybePromise <K> | |
options | { collector?: AsyncReducer.Accept <readonly [K, T], R> | undefined; } |
Overrides
indexed
undocumented
indexed
Definition
indexed(options?: {
startIndex?: number;
}):
AsyncStream
<[number, T]>;
Parameters
Name | Type | Description |
---|---|---|
options | { startIndex?: number; } |
Overrides
indexOf
undocumented
indexOf
Definition
indexOf(searchValue: T, options?: {
occurrance?: number
|
undefined;
eq?: Eq<T>
|
undefined;
negate?: boolean
|
undefined;
}): Promise<number
|
undefined>;
Parameters
Name | Type | Description |
---|---|---|
searchValue | T | |
options | { occurrance?: number | undefined; eq?: Eq<T> | undefined; negate?: boolean | undefined; } |
Overrides
indexWhere
undocumented
indexWhere
Definition
indexWhere(pred: (value: T, index: number) =>
MaybePromise
<boolean>, options?: {
occurrance?: number;
negate?: boolean;
}): Promise<number
|
undefined>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> | |
options | { occurrance?: number; negate?: boolean; } |
Overrides
indicesOf
undocumented
indicesOf
Definition
indicesOf(searchValue: T, options?: {
eq?: Eq<T>;
negate?: boolean;
}):
AsyncStream
<number>;
Parameters
Name | Type | Description |
---|---|---|
searchValue | T | |
options | { eq?: Eq<T>; negate?: boolean; } |
Overrides
indicesWhere
undocumented
indicesWhere
Definition
indicesWhere(pred: (value: T) =>
MaybePromise
<boolean>, options?: {
negate?: boolean;
}):
AsyncStream
<number>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T) => MaybePromise <boolean> | |
options | { negate?: boolean; } |
Overrides
intersperse
undocumented
intersperse
Definition
intersperse(sep:
AsyncStreamSource
<T>):
AsyncStream
<T>;
Parameters
Name | Type | Description |
---|---|---|
sep | AsyncStreamSource <T> |
Overrides
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; } |
Overrides
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> |
Overrides
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 |
Overrides
max
undocumented
max
maxBy
undocumented
maxBy
min
undocumented
min
minBy
undocumented
minBy
mkGroup
undocumented
mkGroup
Definition
mkGroup({ sep, start, end, }?: {
sep?:
AsyncStreamSource
<T>;
start?:
AsyncStreamSource
<T>;
end?:
AsyncStreamSource
<T>;
}): any;
Parameters
Name | Type | Description |
---|---|---|
{ sep, start, end, } | { sep?: AsyncStreamSource <T>; start?: AsyncStreamSource <T>; end?: AsyncStreamSource <T>; } |
Overrides
partition
undocumented
partition
Definition
partition(pred: (value: T, index: number) =>
MaybePromise
<boolean>, options?: {
collectorTrue?: any;
collectorFalse?: any;
}): Promise<[any, any]>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> | |
options | { collectorTrue?: any; collectorFalse?: any; } |
Overrides
prepend
undocumented
prepend
Definition
prepend(value: AsyncOptLazy<T>):
AsyncStream.NonEmpty
<T>;
Parameters
Name | Type | Description |
---|---|---|
value | AsyncOptLazy<T> |
Overrides
reduce
undocumented
reduce
Definition
reduce<const S extends
AsyncReducer.CombineShape
<T>>(shape: S &
AsyncReducer.CombineShape
<T>): Promise<
AsyncReducer.CombineResult
<S>>;
Type parameters
Name | Constraints | Description |
---|---|---|
S | AsyncReducer.CombineShape <T> |
Parameters
Name | Type | Description |
---|---|---|
shape | S & AsyncReducer.CombineShape <T> |
Overrides
reduceStream
undocumented
reduceStream
Definition
reduceStream<const S extends
AsyncReducer.CombineShape
<T>>(shape: S &
AsyncReducer.CombineShape
<T>):
AsyncStream
<
AsyncReducer.CombineResult
<S>>;
Type parameters
Name | Constraints | Description |
---|---|---|
S | AsyncReducer.CombineShape <T> |
Parameters
Name | Type | Description |
---|---|---|
shape | S & AsyncReducer.CombineShape <T> |
Overrides
repeat
undocumented
repeat
Definition
repeat(amount?: number):
AsyncStream
<T>;
Parameters
Name | Type | Description |
---|---|---|
amount | number |
Overrides
single
undocumented
single
some
undocumented
some
Definition
some(pred: (value: T, index: number) =>
MaybePromise
<boolean>, options?: {
negate?: boolean;
}): Promise<boolean>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> | |
options | { negate?: boolean; } |
Overrides
splitOn
undocumented
splitOn
Definition
splitOn<R>(sepElem: T, options?: {
eq?: Eq<T>
|
undefined;
negate?: boolean
|
undefined;
collector?:
AsyncReducer.Accept
<T, R>
|
undefined;
}):
AsyncStream
<R>;
Type parameters
Name | Description |
---|---|
R |
Parameters
Name | Type | Description |
---|---|---|
sepElem | T | |
options | { eq?: Eq<T> | undefined; negate?: boolean | undefined; collector?: AsyncReducer.Accept <T, R> | undefined; } |
Overrides
splitOnSlice
undocumented
splitOnSlice
Definition
splitOnSlice<R>(sepSlice:
AsyncStreamSource
<T>, options?: {
eq?: Eq<T>
|
undefined;
collector?:
AsyncReducer.Accept
<T, R>
|
undefined;
}):
AsyncStream
<R>;
Type parameters
Name | Description |
---|---|
R |
Parameters
Name | Type | Description |
---|---|---|
sepSlice | AsyncStreamSource <T> | |
options | { eq?: Eq<T> | undefined; collector?: AsyncReducer.Accept <T, R> | undefined; } |
Overrides
splitWhere
undocumented
splitWhere
Definition
splitWhere<R>(pred: (value: T, index: number) =>
MaybePromise
<boolean>, options?: {
negate?: boolean
|
undefined;
collector?:
AsyncReducer.Accept
<T, R>
|
undefined;
}):
AsyncStream
<R>;
Type parameters
Name | Description |
---|---|
R |
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> | |
options | { negate?: boolean | undefined; collector?: AsyncReducer.Accept <T, R> | undefined; } |
Overrides
take
undocumented
take
Definition
take(amount: number):
AsyncStream
<T>;
Parameters
Name | Type | Description |
---|---|---|
amount | number |
Overrides
takeWhile
undocumented
takeWhile
Definition
takeWhile(pred: (value: T, index: number) =>
MaybePromise
<boolean>, options?: {
negate?: boolean;
}):
AsyncStream
<T>;
Parameters
Name | Type | Description |
---|---|---|
pred | (value: T, index: number) => MaybePromise <boolean> | |
options | { negate?: boolean; } |
Overrides
toArray
undocumented
toArray
toJSON
undocumented
toJSON
toString
undocumented
toString
transform
undocumented
transform
Definition
transform<R>(transformer:
AsyncTransformer.Accept
<T, R>):
AsyncStream
<R>;
Type parameters
Name | Description |
---|---|
R |
Parameters
Name | Type | Description |
---|---|---|
transformer | AsyncTransformer.Accept <T, R> |
Overrides
window
undocumented
window
Definition
window<R>(windowSize: number, options?: {
skipAmount?: number
|
undefined;
collector?:
AsyncReducer.Accept
<T, R>
|
undefined;
}):
AsyncStream
<R>;
Type parameters
Name | Description |
---|---|
R |
Parameters
Name | Type | Description |
---|---|---|
windowSize | number | |
options | { skipAmount?: number | undefined; collector?: AsyncReducer.Accept <T, R> | undefined; } |