Pipelines

pipelineby hyfather

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

updated 5y ago

ordered-concurrentlyby tejzpr

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

github.com/tejzpr/ordered-concurrently/v3Go 1.12+ No dependencies v3.0.1updated 3y ago

parapipeby nazar256

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

github.com/nazar256/parapipeGo 1.21+ No dependencies v0.5.0updated 1y ago

pipelinesby nxdir-s

Generic pipeline functions for concurrent processing.

github.com/nxdir-s/pipelinesGo 1.26+ No dependencies v1.1.1updated 4mo ago