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.

skills.sh installs: 39.6K
GitHub stars: 3.8K
last updated: Aug 21, 2026

View on GitHub

Install

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

Installs into .claude/skills of the current project.

Files

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.

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.

samber/ro — Reactive Streams for Go

Go implementation of ReactiveX. 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.

Official Resources:

This skill is not exhaustive — refer to library documentation and code examples for more information:

SKILL.md on GitHub