routier-collection / core/src / AsyncPipeline
Class: AsyncPipeline<TData, TResult>
Defined in: core/src/pipeline/TrampolinePipeline.ts:160
Type Parameters
TData
TData
TResult
TResult
Constructors
Constructor
new AsyncPipeline<
TData,TResult>():AsyncPipeline<TData,TResult>
Returns
AsyncPipeline<TData, TResult>
Methods
filter()
filter(
done):void
Defined in: core/src/pipeline/TrampolinePipeline.ts:164
Parameters
done
CallbackResult<TResult[]>
Returns
void
pipe()
pipe(
data,processor):void
Defined in: core/src/pipeline/TrampolinePipeline.ts:288
Parameters
data
TData
processor
AsyncUnitOfWork<TData, TResult>
Returns
void
pipeEach()
pipeEach(
items,processor):void
Defined in: core/src/pipeline/TrampolinePipeline.ts:292
Parameters
items
TData[]
processor
AsyncUnitOfWork<TData, TResult>
Returns
void