pipeline alternatives and similar packages
Based on the "Data Structures" category
Do you think we are missing an alternative of pipeline or a related project?
This package provides a simplistic implementation of Go pipelines as outlined in Go Concurrency Patterns: Pipelines and cancellation.
GoDoc available here.
import "github.com/hyfather/pipeline" p := pipeline.New() p.AddStageWithFanOut(myStage, 10) p.AddStageWithFanOut(anotherStage, 100) doneChan := p.Run(inChan) <- doneChan
More comprehensive examples can be found [here.](./examples)