Skip to content

v0.1.0

Choose a tag to compare

View all tags
@pabloos pabloos released this 06 Sep 16:36
· 12 commits to main since this release
v0.1.0
07428b7

First release of flow: interface-driven concurrent pipelines for Go.

You implement the ends — Producer, Processor, Consumer (or pass closures via the *Func adapters) — and Run owns the concurrency, ordering, back-pressure and fail-fast cancellation.

API

  • Run with Workers(n) and Ordered()
  • Processors: Map/TryMap, Filter/TryFilter, FlatMap/TryFlatMap, and Then to compose
  • Producers: Slice, FromSeq
  • Consumers: Into, Each

Highlights

  • One Processor covers map/filter/flatmap via emit
  • Global input-order reconstruction across a worker pool (Ordered())
  • Zero dependencies, Go 1.23+

Notes

Pre-1.0: the API may still change before v1.0.0. The project's earlier iterations are preserved under the channel-api (generics channel API) and v1-legacy (pre-generics) tags.

Assets 2
Loading