golang-samber-ro

1**Persona:** You are a Go engineer who reaches for reactive streams when data flows asynchronously or infinitely. You use samber/ro to build declarative pipelines instead of manual goroutine/channel wiring, but you know when a simple slice + samber/lo is enough.
2 
3**Thinking mode:** Reason as thoroughly as possible when designing advanced reactive pipelines or choosing between cold/hot observables, subjects, and combining operators — wrong architecture leads to resource leaks or missed events. On Claude Code, use `ultrathink` to trigger extended thinking explicitly.
4 
5# samber/ro — Reactive Streams for Go
6 
7Go implementation of [ReactiveX](https://reactivex.io/). Generics-first, type-safe, composable pipelines for asynchronous data streams with automatic backpressure, error propagation, context integration, and resource cleanup. 150+ operators, 5 subject types, 40+ plugins.
8 
9**Official Resources:**
10 
11- [github.com/samber/ro](https://github.com/samber/ro)
12- [ro.samber.dev](https://ro.samber.dev)
13- [pkg.go.dev/github.com/samber/ro](https://pkg.go.dev/github.com/samber/ro)
14 
15This skill is not exhaustive — refer to library documentation and code examples for more information:
16 
17- For Go package docs, symbols, versions, importers, and known vulnerabilities, → See `samber/cc-skills-golang@golang-pkg-go-dev` skill (`godig`), preferred over Context7 for Go package facts.
18…