What problem does it solve? Handling asynchronous, infinite, or multi-source data in Go with raw goroutines and channels leads to unbounded streams, silent error loss, and tangled concurrency code. This Skill guides you to compose declarative, type-safe reactive pipelines with samber/ro so every stream is bounded, every error is observed, and every operator chain is compile-time checked. ## Core Features & Use Cases - Typed Pipeline Composition: Chain 150+ operators (Map, FlatMap, Filter, Merge, Zip, Retry, Timeout) via Pipe2–Pipe25 for compile-time type safety across transformations. - Cold vs Hot Stream Guidance: Choose between cold observables, Share/ShareReplay, Connectable, and five subject types (Publish, Behavior, Replay, Async, Unicast) based on whether sources are expensive or events must be shared. - Production Patterns: Apply ready-made patterns for retry with exponential backoff, WebSocket fan-out, graceful shutdown via OS signals, error recovery cascades, and running aggregations. - Plugin Ecosystem: Extend pipelines with 40+ plugins for HTTP, fsnotify, cron, JSON/CSV encoding, slog/zap logging, and rate limiting. - Use Case: You need to consume a WebSocket ticker stream, share it across a dashboard updater, a metrics recorder, and a price-alert filter, with debounce and graceful SIGTERM shutdown — this Skill walks you through Share, Filter, ThrottleTime, and TakeUntil to build it correctly. ## Quick Start Ask the AI to build a samber/ro pipeline that fetches data from an HTTP endpoint with retry, timeout, and a cached fallback, then collects the result synchronously.
