Pipes

Go module that processes work concurrently and returns output in a channel in the order of input

FIFO Pipeline which parallels execution on each stage while maintaining the order of messages and results

An implementation of pipelines with fan-in and fan-out

Generic pipeline functions for concurrent processing