Class MidwayPipelineService

Hierarchy

MidwayPipelineService

Implements

IPipelineHandler

Index

Constructors

Properties

applicationContext valves?

Methods

concat concatSeries parallel series waterfall

Constructors

constructor

new MidwayPipelineService(applicationContext: IMidwayContainer, valves?: valvesType): MidwayPipelineService
Parameters
- applicationContext: IMidwayContainer
- Optional valves: valvesType
Returns MidwayPipelineService
- Defined in packages/core/src/service/pipelineService.ts:170

Properties

`Readonly` applicationContext

applicationContext: IMidwayContainer

`Optional` `Readonly` valves

valves?: valvesType

Methods

concat

concat<T>(opts: IPipelineOptions): Promise<IPipelineResult<T>>
并行执行，最终 result 为数组
Type Parameters
- T
Parameters
- opts: IPipelineOptions
  
  执行参数
Returns Promise<IPipelineResult<T>>
Implementation of IPipelineHandler.concat
- Defined in packages/core/src/service/pipelineService.ts:189

concatSeries

concatSeries<T>(opts: IPipelineOptions): Promise<IPipelineResult<T>>
串行执行，使用 foreach await，最终 result 为数组
Type Parameters
- T
Parameters
- opts: IPipelineOptions
  
  执行参数
Returns Promise<IPipelineResult<T>>
Implementation of IPipelineHandler.concatSeries
- Defined in packages/core/src/service/pipelineService.ts:260

parallel

parallel<T>(opts: IPipelineOptions): Promise<IPipelineResult<T>>
并行执行，使用 Promise.all
Type Parameters
- T
Parameters
- opts: IPipelineOptions
  
  执行参数
Returns Promise<IPipelineResult<T>>
Implementation of IPipelineHandler.parallel
- Defined in packages/core/src/service/pipelineService.ts:179

series

series<T>(opts: IPipelineOptions): Promise<IPipelineResult<T>>
串行执行，使用 foreach await
Type Parameters
- T
Parameters
- opts: IPipelineOptions
  
  执行参数
Returns Promise<IPipelineResult<T>>
Implementation of IPipelineHandler.series
- Defined in packages/core/src/service/pipelineService.ts:199

waterfall

waterfall<T>(opts: IPipelineOptions): Promise<IPipelineResult<T>>
串行执行，但是会把前者执行结果当成入参，传入到下一个执行中去，最后一个执行的 valve 结果会被返回
Type Parameters
- T
Parameters
- opts: IPipelineOptions
  
  执行参数
Returns Promise<IPipelineResult<T>>
Implementation of IPipelineHandler.waterfall
- Defined in packages/core/src/service/pipelineService.ts:317

Generated using TypeDoc