Skip to main content

Class: PipeProcessor

A processor for executing pipe definitions.

Implements​

Constructors​

Constructor​

new PipeProcessor(injector): PipeProcessor

Parameters​

injector​

Injector

Returns​

PipeProcessor

Methods​

process()​

process(pipes, context): Promise<any[]>

Processes an array of pipe definitions using the provided execution context.

Parameters​

pipes​

PipeDefinition[]

An array of PipeDefinition instances to process.

context​

ExecutionContext

The execution context containing relevant information for processing.

Returns​

Promise<any[]>

A promise resolving to an array of the processed results.

Implementation of​

Processable.process