pipeline
CategoryData Structures and Algorithms
SubcategoryPipes
Stars0
An implementation of pipelines with fan-in and fan-out
About pipeline
pipeline
This package provides a simplistic implementation of Go pipelines as outlined in Go Concurrency Patterns: Pipelines and cancellation.
Docs
GoDoc available here.
Example Usage
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.
Frequently Asked Questions
What is pipeline?
pipeline is a Data Structures and Algorithms library for the Go programming language. An implementation of pipelines with fan-in and fan-out
How do I install pipeline?
Install pipeline with the Go module system using `go get hyfather/pipeline`. Check the repository for the current installation instructions.
What category does pipeline belong to?
pipeline is listed under Data Structures and Algorithms, specifically Pipes.