NewBusCollector builds a BusCollector to listen on bus channels.

NewCollector builds a CollectorPipeline that reads from a channel of type IN.

NewFeeder builds a new FeederPipeline.

NewInitialChained builds a new initial chain of pipelines.

NewPipeline builds a generic pipeline that collects from a channel of type IN and outputs into a channel of type OUT, without out-of-band notifications on channel of type BUS.

Then allows to chain outputs by declaring explicit types.

WithAutoCloseOutput sets the behavior to close the output channel after the runner is complete.

WithBusBuffers sets a buffered bus channel.

WithInputBuffers sets a buffered input channel.

WithOutputBuffers sets a buffered output cha,nel.

FanInPipeline is a pipeline that gathers several input channels into one single ouput.

FanOutPipeline takes one input and duplicate the input messages to several output channels.

JoinerPipeline is a pipeline that takes input for 2 channels of different types and applies a Joiner method to this input.