A new Go package called 'chans' provides generic channel operations for building concurrent pipelines. Unlike opinionated alternatives, it offers low-level, composable building blocks including filtering, mapping, batching, deduplication, and routing operations. The package gives developers full control over goroutines, error handling, and channel lifecycle while providing essential operations like Filter, Map, Reduce, Chunk, Broadcast, and Merge.

7m read timeFrom antonz.org
Post cover image
Table of contents
The all-time classicsFiltering and samplingBatching and windowingDe-duplicationRoutingMotivationUsage exampleFinal thoughts

Sort: