Class AsyncStream<S>

Type Parameters

S

Hierarchy (View Summary)

AsyncStream
- AsyncFilter
- AsyncSource

Index

Methods

collect filter of

Methods

collect

collect<R>(collector: Collector<S, R>): Promise<R>
Type Parameters
- R
Parameters
- collector: Collector<S, R>
Returns Promise<R>
- 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>
- 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>
- Defined in libs/core/src/lib/util/stream.ts:39