MidwayPipelineService

Implements

• IPipelineHandler

Index

Constructors

• constructor

Properties

• applicationContext
• valves

Methods

• concat
• concatSeries
• parallel
• series
• waterfall

Constructors

constructor

• new MidwayPipelineService(applicationContext: IMidwayContainer, valves?: valvesType): MidwayPipelineService

Properties

readonlyapplicationContext

applicationContext: IMidwayContainer

optionalreadonlyvalves

valves?: valvesType

Methods

concat

• concat<T>(opts: IPipelineOptions): Promise<IPipelineResult<T>>

• Implementation of IPipelineHandler.concat

  并行执行，最终 result 为数组

  ---

  Type parameters

  • T

concatSeries

• concatSeries<T>(opts: IPipelineOptions): Promise<IPipelineResult<T>>

• Implementation of IPipelineHandler.concatSeries

  串行执行，使用 foreach await，最终 result 为数组

  ---

  Type parameters

  • T

parallel

• parallel<T>(opts: IPipelineOptions): Promise<IPipelineResult<T>>

• Implementation of IPipelineHandler.parallel

  并行执行，使用 Promise.all

  ---

  Type parameters

  • T

series

• series<T>(opts: IPipelineOptions): Promise<IPipelineResult<T>>

• Implementation of IPipelineHandler.series

  串行执行，使用 foreach await

  ---

  Type parameters

  • T

waterfall

• waterfall<T>(opts: IPipelineOptions): Promise<IPipelineResult<T>>

• Implementation of IPipelineHandler.waterfall

  串行执行，但是会把前者执行结果当成入参，传入到下一个执行中去，最后一个执行的 valve 结果会被返回

  ---

  Type parameters

  • T