Skip to content

routier-collection


routier-collection / core/src / WorkPipeline

Class: WorkPipeline

Defined in: core/src/pipeline/TrampolinePipeline.ts:182

Processes functions with callbacks asynchronously.

This pipeline handles work items that contain callback functions, executing them in an asynchronous manner while maintaining proper flow control and error handling.

Constructors

Constructor

new WorkPipeline(): WorkPipeline

Returns

WorkPipeline

Methods

filter()

filter(done): void

Defined in: core/src/pipeline/TrampolinePipeline.ts:186

Parameters

done

CallbackResult<never>

Returns

void


pipe()

pipe(work): void

Defined in: core/src/pipeline/TrampolinePipeline.ts:312

Parameters

work

UnitOfWork

Returns

void

Released under the MIT License.