Class AsyncPipelineOperator<TInput, TOutput>

Async operator pipeline. Accepts both synchronous (OperatorInterface) and asynchronous (AsyncOperatorInterface) operators. Each step is executed via await — a sync operator is unwrapped as a no-op.

Type Parameters

TInput
TOutput

Implements

AsyncOperatorInterface<TInput, TOutput>

Index

Constructors

Methods

Constructors

constructor

new AsyncPipelineOperator<TInput, TOutput>(
    operators: (
        | OperatorInterface<unknown, unknown>
        | AsyncOperatorInterface<unknown, unknown>
    )[],
): AsyncPipelineOperator<TInput, TOutput>
Type Parameters
- TInput
- TOutput
Parameters
- operators: (OperatorInterface<unknown, unknown> | AsyncOperatorInterface<unknown, unknown>)[]
Returns AsyncPipelineOperator<TInput, TOutput>
- Defined in operators.ts:158

Methods

apply

apply(data: TInput): Promise<TOutput>
Parameters
- data: TInput
Returns Promise<TOutput>
Implementation of AsyncOperatorInterface.apply
- Defined in operators.ts:162