Class AsyncStream<T>

Wrapper class to extend the functionality of an Iterable

Type Parameters

Hierarchy (View Summary)

AsyncStream
- Stream

Implements

AsyncIterable<T>

Index

Constructors

constructor

Methods

[asyncIterator] collectAsync pipeAsync

Constructors

constructor

new AsyncStream<T>(
asyncIterable?: null | AsyncIterable<T, any, any>,
): AsyncStream<T>
Type Parameters
- T
Parameters
- asyncIterable: null | AsyncIterable<T, any, any> = null
Returns AsyncStream<T>
- Defined in async-stream.ts:13

Methods

[asyncIterator]

"[asyncIterator]"(): AsyncIterator<T>
Returns AsyncIterator<T>
Implementation of AsyncIterable.[asyncIterator]
- Defined in async-stream.ts:7

collectAsync

collectAsync<O>(collector: AsyncCollectorFunction<T, O>): PromiseLike<O>
Calls a collector function on the Iterable
Type Parameters
- O
Parameters
- collector: AsyncCollectorFunction<T, O>
Returns PromiseLike<O>
- Defined in async-stream.ts:16

pipeAsync

pipeAsync(): AsyncStream<T>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.

Returns AsyncStream<T>
- Defined in async-stream.ts:22
pipeAsync<A>(op1: AsyncOperationFunction<T, A>): AsyncStream<A>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Type Parameters
- A
Parameters
- op1: AsyncOperationFunction<T, A>
Returns AsyncStream<A>
- Defined in async-stream.ts:23
pipeAsync<A, B>(
op1: AsyncOperationFunction<T, A>,
op2: AsyncOperationFunction<A, B>,
): AsyncStream<B>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Type Parameters
- A
- B
Parameters
- op1: AsyncOperationFunction<T, A>
- op2: AsyncOperationFunction<A, B>
Returns AsyncStream<B>
- Defined in async-stream.ts:24
pipeAsync<A, B, C>(
    op1: AsyncOperationFunction<T, A>,
    op2: AsyncOperationFunction<A, B>,
    op3: AsyncOperationFunction<B, C>,
): AsyncStream<C>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Type Parameters
- A
- B
- C
Parameters
- op1: AsyncOperationFunction<T, A>
- op2: AsyncOperationFunction<A, B>
- op3: AsyncOperationFunction<B, C>
Returns AsyncStream<C>
- Defined in async-stream.ts:28
pipeAsync<A, B, C, D>(
    op1: AsyncOperationFunction<T, A>,
    op2: AsyncOperationFunction<A, B>,
    op3: AsyncOperationFunction<B, C>,
    op4: AsyncOperationFunction<C, D>,
): AsyncStream<D>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Type Parameters
- A
- B
- C
- D
Parameters
- op1: AsyncOperationFunction<T, A>
- op2: AsyncOperationFunction<A, B>
- op3: AsyncOperationFunction<B, C>
- op4: AsyncOperationFunction<C, D>
Returns AsyncStream<D>
- Defined in async-stream.ts:33
pipeAsync<A, B, C, D, E>(
    op1: AsyncOperationFunction<T, A>,
    op2: AsyncOperationFunction<A, B>,
    op3: AsyncOperationFunction<B, C>,
    op4: AsyncOperationFunction<C, D>,
    op5: AsyncOperationFunction<D, E>,
): AsyncStream<E>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Type Parameters
- A
- B
- C
- D
- E
Parameters
- op1: AsyncOperationFunction<T, A>
- op2: AsyncOperationFunction<A, B>
- op3: AsyncOperationFunction<B, C>
- op4: AsyncOperationFunction<C, D>
- op5: AsyncOperationFunction<D, E>
Returns AsyncStream<E>
- Defined in async-stream.ts:39
pipeAsync<A, B, C, D, E, F>(
    op1: AsyncOperationFunction<T, A>,
    op2: AsyncOperationFunction<A, B>,
    op3: AsyncOperationFunction<B, C>,
    op4: AsyncOperationFunction<C, D>,
    op5: AsyncOperationFunction<D, E>,
    op6: AsyncOperationFunction<E, F>,
): AsyncStream<F>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Type Parameters
- A
- B
- C
- D
- E
- F
Parameters
- op1: AsyncOperationFunction<T, A>
- op2: AsyncOperationFunction<A, B>
- op3: AsyncOperationFunction<B, C>
- op4: AsyncOperationFunction<C, D>
- op5: AsyncOperationFunction<D, E>
- op6: AsyncOperationFunction<E, F>
Returns AsyncStream<F>
- Defined in async-stream.ts:46
pipeAsync<A, B, C, D, E, F, G>(
    op1: AsyncOperationFunction<T, A>,
    op2: AsyncOperationFunction<A, B>,
    op3: AsyncOperationFunction<B, C>,
    op4: AsyncOperationFunction<C, D>,
    op5: AsyncOperationFunction<D, E>,
    op6: AsyncOperationFunction<E, F>,
    op7: AsyncOperationFunction<F, G>,
): AsyncStream<G>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Type Parameters
- A
- B
- C
- D
- E
- F
- G
Parameters
- op1: AsyncOperationFunction<T, A>
- op2: AsyncOperationFunction<A, B>
- op3: AsyncOperationFunction<B, C>
- op4: AsyncOperationFunction<C, D>
- op5: AsyncOperationFunction<D, E>
- op6: AsyncOperationFunction<E, F>
- op7: AsyncOperationFunction<F, G>
Returns AsyncStream<G>
- Defined in async-stream.ts:54
pipeAsync<A, B, C, D, E, F, G, H>(
    op1: AsyncOperationFunction<T, A>,
    op2: AsyncOperationFunction<A, B>,
    op3: AsyncOperationFunction<B, C>,
    op4: AsyncOperationFunction<C, D>,
    op5: AsyncOperationFunction<D, E>,
    op6: AsyncOperationFunction<E, F>,
    op7: AsyncOperationFunction<F, G>,
    op8: AsyncOperationFunction<G, H>,
): AsyncStream<H>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Type Parameters
- A
- B
- C
- D
- E
- F
- G
- H
Parameters
- op1: AsyncOperationFunction<T, A>
- op2: AsyncOperationFunction<A, B>
- op3: AsyncOperationFunction<B, C>
- op4: AsyncOperationFunction<C, D>
- op5: AsyncOperationFunction<D, E>
- op6: AsyncOperationFunction<E, F>
- op7: AsyncOperationFunction<F, G>
- op8: AsyncOperationFunction<G, H>
Returns AsyncStream<H>
- Defined in async-stream.ts:63
pipeAsync<A, B, C, D, E, F, G, H, I>(
    op1: AsyncOperationFunction<T, A>,
    op2: AsyncOperationFunction<A, B>,
    op3: AsyncOperationFunction<B, C>,
    op4: AsyncOperationFunction<C, D>,
    op5: AsyncOperationFunction<D, E>,
    op6: AsyncOperationFunction<E, F>,
    op7: AsyncOperationFunction<F, G>,
    op8: AsyncOperationFunction<G, H>,
    op9: AsyncOperationFunction<H, I>,
): AsyncStream<H>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Type Parameters
- A
- B
- C
- D
- E
- F
- G
- H
- I
Parameters
- op1: AsyncOperationFunction<T, A>
- op2: AsyncOperationFunction<A, B>
- op3: AsyncOperationFunction<B, C>
- op4: AsyncOperationFunction<C, D>
- op5: AsyncOperationFunction<D, E>
- op6: AsyncOperationFunction<E, F>
- op7: AsyncOperationFunction<F, G>
- op8: AsyncOperationFunction<G, H>
- op9: AsyncOperationFunction<H, I>
Returns AsyncStream<H>
- Defined in async-stream.ts:73
pipeAsync<A, B, C, D, E, F, G, H, I>(
    op1: AsyncOperationFunction<T, A>,
    op2: AsyncOperationFunction<A, B>,
    op3: AsyncOperationFunction<B, C>,
    op4: AsyncOperationFunction<C, D>,
    op5: AsyncOperationFunction<D, E>,
    op6: AsyncOperationFunction<E, F>,
    op7: AsyncOperationFunction<F, G>,
    op8: AsyncOperationFunction<G, H>,
    op9: AsyncOperationFunction<H, I>,
): AsyncStream<I>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Type Parameters
- A
- B
- C
- D
- E
- F
- G
- H
- I
Parameters
- op1: AsyncOperationFunction<T, A>
- op2: AsyncOperationFunction<A, B>
- op3: AsyncOperationFunction<B, C>
- op4: AsyncOperationFunction<C, D>
- op5: AsyncOperationFunction<D, E>
- op6: AsyncOperationFunction<E, F>
- op7: AsyncOperationFunction<F, G>
- op8: AsyncOperationFunction<G, H>
- op9: AsyncOperationFunction<H, I>
Returns AsyncStream<I>
- Defined in async-stream.ts:84
pipeAsync(...ops: AsyncOperationFunction<T, T>[]): AsyncStream<T>
Calls an operation function on the Iterable then returns the result as a Stream allowing to chain it with more Stream related methods.
Parameters
- ...ops: AsyncOperationFunction<T, T>[]
Returns AsyncStream<T>
- Defined in async-stream.ts:95

Class AsyncStream<T>

Type Parameters

Hierarchy (View Summary)

Implements

Index

Constructors

Methods

Constructors

constructor

Type Parameters

Parameters

Returns AsyncStream<T>

Methods

[asyncIterator]

Returns AsyncIterator<T>

collectAsync

Type Parameters

Parameters

Returns PromiseLike<O>

pipeAsync

Returns AsyncStream<T>

Type Parameters

Parameters

Returns AsyncStream<A>

Type Parameters

Parameters

Returns AsyncStream<B>

Type Parameters

Parameters

Returns AsyncStream<C>

Type Parameters

Parameters

Returns AsyncStream<D>

Type Parameters

Parameters

Returns AsyncStream<E>

Type Parameters

Parameters

Returns AsyncStream<F>

Type Parameters

Parameters

Returns AsyncStream<G>

Type Parameters

Parameters

Returns AsyncStream<H>

Type Parameters

Parameters

Returns AsyncStream<H>

Type Parameters

Parameters

Returns AsyncStream<I>

Parameters

Returns AsyncStream<T>

Settings

On This Page