Golang Samber Ro

samber/ro brings ReactiveX to Go with 150+ type-safe operators for building declarative async pipelines. Instead of wiring goroutines and channels by hand, you compose streams with Map, Filter, CombineLatest, and friends. It handles backpressure, error propagation, and cleanup automatically. The cold/hot observable model plus five subject types (Publish, Behavior, Replay, Async, Unicast) cover everything from simple event processing to complex multi-source data flows. Reach for this when you're dealing with infinite streams, WebSockets, file watchers, or real-time processing. For finite slice transforms, stick with samber/lo. The typed Pipe2 through Pipe25 functions enforce correctness at compile time, which matters when pipelines get deep.

Install to Claude Code

npx -y skills add samber/cc-skills-golang --skill golang-samber-ro --agent claude-code