`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

Definition

abstract [Symbol.asyncIterator](): AsyncFastIterator<T>;

`append`

undocumented

Definition

append(value: AsyncOptLazy<T>): AsyncStream.NonEmpty<T>;

Parameters

Name	Type	Description
`value`	`AsyncOptLazy<T>`

`asNormal`

undocumented

Definition

asNormal(): AsyncStream<T>;

`assumeNonEmpty`

undocumented

Definition

assumeNonEmpty(): AsyncStream.NonEmpty<T>;

`asyncStream`

undocumented

Definition

asyncStream(): this;

`collect`

undocumented

Definition

collect<R>(collectFun: AsyncCollectFun<T, R>): AsyncStream<R>;

Type parameters

Name	Description
R

Parameters

Name	Type	Description
`collectFun`	`AsyncCollectFun<T, R>`

`concat`

undocumented

Definition

concat(...others: ArrayNonEmpty<AsyncStreamSource<T>>): any;

Parameters

Name	Type	Description
`others`	`ArrayNonEmpty<AsyncStreamSource<T>>`

`contains`

undocumented

Definition

contains(searchValue: T, amount?: number, eq?: Eq<T>): Promise<boolean>;

Parameters

Name	Type	Description
`searchValue`	`T`
`amount`	`number`
`eq`	`Eq<T>`

`containsSlice`

undocumented

Definition

containsSlice(source: AsyncStreamSource.NonEmpty<T>, eq?: Eq<any>): Promise<boolean>;

Parameters

Name	Type	Description
`source`	`AsyncStreamSource.NonEmpty<T>`
`eq`	`Eq<any>`

`count`

undocumented

Definition

count(): Promise<number>;

`countElement`

undocumented

Definition

countElement(value: T, eq?: Eq<any>): Promise<number>;

Parameters

Name	Type	Description
`value`	`T`
`eq`	`Eq<any>`

`countNotElement`

undocumented

Definition

countNotElement(value: T, eq?: Eq<any>): Promise<number>;

Parameters

Name	Type	Description
`value`	`T`
`eq`	`Eq<any>`

`distinctPrevious`

undocumented

Definition

distinctPrevious(eq?: Eq<T>): AsyncStream<T>;

Parameters

Name	Type	Description
`eq`	`Eq<T>`

`drop`

undocumented

Definition

drop(amount: number): AsyncStream<T>;

Parameters

Name	Type	Description
`amount`	`number`

`dropWhile`

undocumented

Definition

dropWhile(pred: (value: T, index: number) => MaybePromise<boolean>): AsyncStream<T>;

Parameters

Name	Type	Description
`pred`	`(value: T, index: number) =>` `MaybePromise<boolean>`

`elementAt`

undocumented

Definition

elementAt<O>(index: number, otherwise?: AsyncOptLazy<O>): Promise<T | O>;

Type parameters

Name	Description
O

Parameters

Name	Type	Description
`index`	`number`
`otherwise`	`AsyncOptLazy<O>`

`equals`

undocumented

Definition

equals(other: AsyncStreamSource<T>, eq?: Eq<T>): Promise<boolean>;

Parameters

Name	Type	Description
`other`	`AsyncStreamSource<T>`
`eq`	`Eq<T>`

`every`

undocumented

Definition

every(pred: (value: T, index: number) => MaybePromise<boolean>): Promise<boolean>;

Parameters

Name	Type	Description
`pred`	`(value: T, index: number) =>` `MaybePromise<boolean>`

`filter`

undocumented

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

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

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

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

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

Definition

first<O>(otherwise?: AsyncOptLazy<O>): Promise<T | O>;

Type parameters

Name	Description
O

Parameters

Name	Type	Description
`otherwise`	`AsyncOptLazy<O>`

`flatMap`

undocumented

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>`

`flatZip`

undocumented

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>`

`fold`

undocumented

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

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

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

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

Definition

indexed(startIndex?: number): AsyncStream<[number, T]>;

Parameters

Name	Type	Description
`startIndex`	`number`

`indexOf`

undocumented

Definition

indexOf(searchValue: T, occurrance?: number, eq?: Eq<T>): Promise<number | undefined>;

Parameters

Name	Type	Description
`searchValue`	`T`
`occurrance`	`number`
`eq`	`Eq<T>`

`indexWhere`

undocumented

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

Definition

indicesOf(searchValue: T, eq?: Eq<T>): AsyncStream<number>;

Parameters

Name	Type	Description
`searchValue`	`T`
`eq`	`Eq<T>`

`indicesWhere`

undocumented

Definition

indicesWhere(pred: (value: T) => MaybePromise<boolean>): AsyncStream<number>;

Parameters

Name	Type	Description
`pred`	`(value: T) =>` `MaybePromise<boolean>`

`intersperse`

undocumented

Definition

intersperse(sep: AsyncStreamSource<T>): AsyncStream<T>;

Parameters

Name	Type	Description
`sep`	`AsyncStreamSource<T>`

`join`

undocumented

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

Definition

last<O>(otherwise?: AsyncOptLazy<O>): Promise<T | O>;

Type parameters

Name	Description
O

Parameters

Name	Type	Description
`otherwise`	`AsyncOptLazy<O>`

`map`

undocumented

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

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

Definition

max<O>(otherwise?: AsyncOptLazy<O>): Promise<T | O>;

Type parameters

Name	Description
O

Parameters

Name	Type	Description
`otherwise`	`AsyncOptLazy<O>`

`maxBy`

undocumented

Definition

maxBy<O>(compare: (v1: T, v2: T) => number, otherwise?: AsyncOptLazy<O>): Promise<T | O>;

Type parameters

Name	Description
O

Parameters

Name	Type	Description
`compare`	`(v1: T, v2: T) => number`
`otherwise`	`AsyncOptLazy<O>`

`min`

undocumented

Definition

min<O>(otherwise?: AsyncOptLazy<O>): Promise<T | O>;

Type parameters

Name	Description
O

Parameters

Name	Type	Description
`otherwise`	`AsyncOptLazy<O>`

`minBy`

undocumented

Definition

minBy<O>(compare: (v1: T, v2: T) => number, otherwise?: AsyncOptLazy<O>): Promise<T | O>;

Type parameters

Name	Description
O

Parameters

Name	Type	Description
`compare`	`(v1: T, v2: T) => number`
`otherwise`	`AsyncOptLazy<O>`

`mkGroup`

undocumented

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>;` `}`

`prepend`

undocumented

Definition

prepend(value: AsyncOptLazy<T>): AsyncStream.NonEmpty<T>;

Parameters

Name	Type	Description
`value`	`AsyncOptLazy<T>`

`reduce`

undocumented

Definition

reduce<R>(reducer: AsyncReducer<T, R>): Promise<R>;

Type parameters

Name	Description
R

Parameters

Name	Type	Description
`reducer`	`AsyncReducer<T, R>`

`reduceAll`

undocumented

Definition

reduceAll<R extends [unknown, unknown, ...unknown[]]>(...reducers: {
    [K in keyof R]: AsyncReducer<T, R[K]>;
  }): Promise<any>;

Type parameters

Name	Constraints	Description
R	`[unknown, unknown, ...unknown[]]`

Parameters

Name	Type	Description
`reducers`	`{` `[K in keyof R]: AsyncReducer<T, R[K]>;` `}`

`reduceAllStream`

undocumented

Definition

reduceAllStream<R extends [unknown, unknown, ...unknown[]]>(...reducers: {
    [K in keyof R]: AsyncReducer<T, R[K]>;
  }): any;

Type parameters

Name	Constraints	Description
R	`[unknown, unknown, ...unknown[]]`

Parameters

Name	Type	Description
`reducers`	`{` `[K in keyof R]: AsyncReducer<T, R[K]>;` `}`

`reduceStream`

undocumented

Definition

reduceStream<R>(reducer: AsyncReducer<T, R>): AsyncStream<R>;

Type parameters

Name	Description
R

Parameters

Name	Type	Description
`reducer`	`AsyncReducer<T, R>`

`repeat`

undocumented

Definition

repeat(amount?: number): AsyncStream<T>;

Parameters

Name	Type	Description
`amount`	`number`

`single`

undocumented

Definition

single<O>(otherwise?: AsyncOptLazy<O>): Promise<T | O>;

Type parameters

Name	Description
O

Parameters

Name	Type	Description
`otherwise`	`AsyncOptLazy<O>`

`some`

undocumented

Definition

some(pred: (value: T, index: number) => MaybePromise<boolean>): Promise<boolean>;

Parameters

Name	Type	Description
`pred`	`(value: T, index: number) =>` `MaybePromise<boolean>`

`splitOn`

undocumented

Definition

splitOn(sepElem: T, eq?: Eq<T>): AsyncStream<T[]>;

Parameters

Name	Type	Description
`sepElem`	`T`
`eq`	`Eq<T>`

`splitWhere`

undocumented

Definition

splitWhere(pred: (value: T, index: number) => MaybePromise<boolean>): AsyncStream<T[]>;

Parameters

Name	Type	Description
`pred`	`(value: T, index: number) =>` `MaybePromise<boolean>`

`take`

undocumented

Definition

take(amount: number): AsyncStream<T>;

Parameters

Name	Type	Description
`amount`	`number`

`takeWhile`

undocumented

Definition

takeWhile(pred: (value: T, index: number) => MaybePromise<boolean>): AsyncStream<T>;

Parameters

Name	Type	Description
`pred`	`(value: T, index: number) =>` `MaybePromise<boolean>`

`toArray`

undocumented

Definition

toArray(): Promise<T[]>;

`toJSON`

undocumented

Definition

toJSON(): Promise<ToJSON<T[], 'AsyncStream'>>;

`toString`

undocumented

Definition

toString(): string;

`transform`

undocumented

Definition

transform<R>(transformer: AsyncReducer<T, AsyncStreamSource<R>>): AsyncStream<R>;

Type parameters

Name	Description
R

Parameters

Name	Type	Description
`transformer`	`AsyncReducer<T, AsyncStreamSource<R>>`

`window`

undocumented

Definition

window<R>(windowSize: number, skipAmount?: number, collector?: AsyncReducer<T, R>): AsyncStream<R>;

Type parameters

Name	Description
R

Parameters

Name	Type	Description
`windowSize`	`number`
`skipAmount`	`number`
`collector`	`AsyncReducer<T, R>`

abstract class AsyncStreamBase<T>

Type parameters​

Methods​

[Symbol.asyncIterator]​

Definition​

append​

Definition​

Parameters​

asNormal​

Definition​

assumeNonEmpty​

Definition​

asyncStream​

Definition​

collect​

Definition​

Type parameters​

Parameters​

concat​

Definition​

Parameters​

contains​

Definition​

Parameters​

containsSlice​

Definition​

Parameters​

count​

Definition​

countElement​

Definition​

Parameters​

countNotElement​

Definition​

Parameters​

distinctPrevious​

Definition​

Parameters​

drop​

Definition​

Parameters​

dropWhile​

Definition​

Parameters​

elementAt​

Definition​

Type parameters​

Parameters​

equals​

Definition​

Parameters​

every​

Definition​

Parameters​

filter​

Definition​

Parameters​

filterNot​

Definition​

Parameters​

filterNotPure​

Definition​

Type parameters​

Parameters​

filterPure​

Definition​

Type parameters​

Parameters​

find​

Definition​

Type parameters​

Parameters​

first​

Definition​

Type parameters​

Parameters​

flatMap​

Definition​

Type parameters​

Parameters​

`abstract class AsyncStreamBase<T>`

Type parameters

Methods

`[Symbol.asyncIterator]`

Definition

`append`

Definition

Parameters

`asNormal`

Definition

`assumeNonEmpty`

Definition

`asyncStream`

Definition

`collect`

Definition

Type parameters

Parameters

`concat`

Definition

Parameters

`contains`

Definition

Parameters

`containsSlice`

Definition

Parameters

`count`

Definition

`countElement`

Definition

Parameters

`countNotElement`

Definition

Parameters

`distinctPrevious`

Definition

Parameters

`drop`

Definition

Parameters

`dropWhile`

Definition

Parameters

`elementAt`

Definition

Type parameters

Parameters

`equals`

Definition

Parameters

`every`

Definition

Parameters

`filter`

Definition

Parameters

`filterNot`

Definition

Parameters

`filterNotPure`

Definition

Type parameters

Parameters

`filterPure`

Definition

Type parameters

Parameters

`find`

Definition

Type parameters

Parameters

`first`

Definition

Type parameters

Parameters

`flatMap`

Definition

Type parameters

Parameters