golang-samber-ro
samber/cc-skills-golang
A type-safe, declarative implementation of ReactiveX in Go. This library enables robust handling of infinite, asynchronous event streams (like WebSockets or tickers) by providing composable operators, automatic backpressure management, and error propagation. It is designed to replace complex, error-prone manual channel and goroutine wiring, allowing developers to build predictable, real-time, event-driven pipelines.