Type-safe Generics
Every operator is fully generic. The compiler catches type mismatches at build time, not at runtime.
goflowType-safe Stream Processing for Go
Composable, concurrent, context-aware stream pipelines built on Go generics
Skip to content
Composable Operators
Chain Map, Filter, FlatMap, Reduce, and 30+ other operators into expressive, readable pipelines.
Concurrency Primitives
FanOut, FanIn, FanMap, Tee, and Process give you parallel pipelines with minimal boilerplate.
Context-Aware
Every stream carries a context.Context. Cancellation propagates automatically through the entire pipeline.
OpenTelemetry Tracing
Built on gofuncy, every goroutine is named and traceable. Plug in your own error handler and span options.
iter.Seq Integration
Convert between streams and Go 1.23 iterators with Iter(), Iter2(), and FromIter() for seamless interop.