Class: pipeline<T>
pipeline.pipeline
Type parameters
| Name | Type |
|---|---|
T | unknown |
Constructors
constructor
• new pipeline<T>()
Type parameters
| Name | Type |
|---|---|
T | unknown |
Properties
operations
• Private operations: Operation<unknown, unknown>[] = []
Defined in
Methods
add
▸ add<TResult>(operation): pipeline<TResult>
Type parameters
| Name |
|---|
TResult |
Parameters
| Name | Type |
|---|---|
operation | Operation<T, TResult> | AsyncIterable<TResult> | Iterable<TResult> |
Returns
pipeline<TResult>
fork
▸ fork(numberOfForks?): Promise<pipeline<T>[]>
Parameters
| Name | Type | Default value |
|---|---|---|
numberOfForks | number | 2 |
Returns
Promise<pipeline<T>[]>
group
▸ group<TKey, TResult>(createKey?, reduce?): pipeline<[TKey, TResult]>
Type parameters
| Name | Type |
|---|---|
TKey | T |
TResult | T[] |
Parameters
| Name | Type |
|---|---|
createKey? | (i: T) => TKey |
reduce? | (group: T[]) => TResult |
Returns
pipeline<[TKey, TResult]>
join
▸ join<R, TResult>(operation, match?, merge?): pipeline<TResult>
Type parameters
| Name | Type |
|---|---|
R | R |
TResult | [T, R] |
Parameters
| Name | Type |
|---|---|
operation | Operation<R, R> | AsyncIterable<R> |
match? | MatchCondition<T, R> |
merge? | MergeOperation<T, R, TResult> |
Returns
pipeline<TResult>
run
▸ run(): AsyncGenerator<Awaited<T>, void, undefined>
Returns
AsyncGenerator<Awaited<T>, void, undefined>