golang-samber-ro

Reactive streams and event-driven programming in Golang using samber/ro — ReactiveX implementation with 150+ type-safe operators, cold/hot observables, 5 subject types (Publish, Behavior, Replay, Async, Unicast), declarative pipelines via Pipe, 40+ plugins (HTTP, cron, fsnotify, JSON, logging), automatic backpressure, error propagation, and Go context integration. Apply when using or adopting samber/ro, when the codebase imports github.com/samber/ro, or when building asynchronous event-driven pi

1,807stars118forksUpdated 5/24/2026

Developer Tools #event-driven #real-time-processing #reactive-programming #asynchronous #golang #streams

Security Assessment

Safe(100/100)

Security Score100/100

About golang-samber-ro

The `golang-samber-ro` skill provides a comprehensive framework for reactive streams and event-driven programming in Go using the samber/ro library, a generics-first implementation of ReactiveX. It addresses the challenges developers face when building complex asynchronous pipelines with Go channels and goroutines, such as manual channel closures, verbose goroutine management, and complicated error propagation. By offering a declarative, chainable approach to streams, this skill simplifies the construction of asynchronous, real-time data workflows while integrating seamlessly with Go's context and providing automatic backpressure and error handling.

FAQ

What does the golang-samber-ro skill help me achieve?

It enables building asynchronous, event-driven pipelines in Go using samber/ro. You can process infinite or time-based streams declaratively, handle errors automatically, and integrate with Go contexts for resource management.

Which Go projects is this skill compatible with?

It is designed for projects that use Go and specifically import github.com/samber/ro. It works well for AI coding agents like Claude Code or similar environments.

Can I use this skill for finite slice transformations?

No, for finite slice transformations, you should use samber/lo or other synchronous collection tools. This skill is optimized for asynchronous streams, event-driven architectures, and real-time data processing.

What are the main types of observables and subjects supported?

The skill supports both cold and hot observables and five subject types: Publish, Behavior, Replay, Async, and Unicast, allowing for versatile stream management and multicasting.

Are there plugins or integrations available?

Yes, there are over 40 plugins including HTTP, cron, fsnotify, JSON, and logging, which can be used within reactive pipelines for extended functionality.