Class AsyncSource<S>

Type Parameters

S

Hierarchy (View Summary)

AsyncStream<S>
- AsyncSource

Index

Constructors

Methods

[asyncIterator] collect filter of

Constructors

constructor

new AsyncSource<S>(source: AsyncIterable<S>): AsyncSource<S>
Type Parameters
- S
Parameters
- source: AsyncIterable<S>
Returns AsyncSource<S>
Overrides AsyncStream<S>.constructor
- Defined in libs/core/src/lib/util/stream.ts:295

Methods

[asyncIterator]

"[asyncIterator]"(): AsyncIterableIterator<S>
Returns AsyncIterableIterator<S>
- Defined in libs/core/src/lib/util/stream.ts:301

collect

collect<R>(collector: Collector<S, R>): Promise<R>
Type Parameters
- R
Parameters
- collector: Collector<S, R>
Returns Promise<R>
Inherited from AsyncStream.collect
- Defined in libs/core/src/lib/util/stream.ts:55

filter

filter(predicate: (element: S) => boolean): AsyncStream<S>
Parameters
- predicate: (element: S) => boolean
Returns AsyncStream<S>
Inherited from AsyncStream.filter
- Defined in libs/core/src/lib/util/stream.ts:51

`Static`of

of<S>(source: AsyncIterable<S>): AsyncSource<S>
Type Parameters
- S
Parameters
- source: AsyncIterable<S>
Returns AsyncSource<S>
Inherited from AsyncStream.of
- Defined in libs/core/src/lib/util/stream.ts:39