golang-samber-roReactive 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 pipelines, real-time data processing, streams, or reactive architectures in Go. Not for finite slice transforms (→ See `samber/cc-skills-golang@golang-samber-lo` skill).
Install via ClawdBot CLI:
clawdbot install samber/golang-samber-roGrade Fair — based on market validation, documentation quality, package completeness, maintenance status, and authenticity signals.
Accesses system directories or attempts privilege escalation
/var/log/Calls external URL not in known-safe list
https://github.com/samber/cc-skills-golangAI Analysis
The skill definition is a documentation and guidance resource for a legitimate open-source Go library (samber/ro). The flagged signals are benign: the '/var/log/' reference is likely in example context, and the external URL points to the skill's own public GitHub repository. No evidence of data exfiltration, credential harvesting, hidden instructions, or obfuscation.
Audited Apr 17, 2026 · audit v1.0
Generated May 9, 2026
Build reactive pipelines to consume and process live stock tick data with backpressure, combining multiple exchanges and applying real-time filters for price thresholds. Hot observables ensure all subscribers see the same ticks without redundant network connections.
Ingest high-frequency sensor readings from thousands of devices using cold observables per device, apply windowed operators (throttle, debounce) to reduce noise, and emit alerts when anomalies are detected. Subjects allow event-driven dashboards to consume processed data.
Orchestrate a chain of microservices where each service emits events via BehaviorSubject. Use CombineLatest to trigger downstream workflows only when all required upstream events arrive, with error propagation and retry operators ensuring resilience.
Use ReplaySubject to broadcast live score updates to connected game clients. Late joiners automatically receive recent scores via replay buffer. Operators like sample and debounce control update frequency to reduce network load.
Create an async pipeline that streams container logs from multiple pods using fsnotify and HTTP plugins. Filter, transform, and batch log entries with backpressure-aware operators, and publish to centralized storage via samber/ro plugins.
Offer a managed platform that ingests, processes, and analyzes real-time data streams for clients. Use samber/ro to build robust pipelines with backpressure and error handling, enabling custom alerting and dashboarding.
Provide an enterprise IoT middleware product that routes sensor events to multiple consumers. Leverage samber/ro's hot observables and subject types to handle multicast, replay, and late-joining subscribers.
Develop and sell a developer toolkit (SDK, plugins, training) that simplifies building reactive microservices in Go. samber/ro forms the core reactive engine, supplemented with plugins for HTTP, Cron, etc.
💬 Integration Tip
Start by replacing manual goroutine+channel patterns for async data flows with ro observables; use Pipe to chain operators and ensure proper cleanup with context cancellation to avoid goroutine leaks.
Scored Sep 28, 2026
Control desktop applications on Windows — launch, close, focus, resize, move windows, simulate keyboard/mouse input, manage processes, control VSCode, read clipboard, and capture screen info. Use when the user wants to interact with any running program, switch windows, type text, press shortcuts, open files in VSCode, manage running processes, or get system display information.
Conduct rigorous, adversarial code reviews with zero tolerance for mediocrity. Use when users ask to "critically review" my code or a PR, "critique my code", "find issues in my code", or "what's wrong with this code". Identifies security holes, lazy patterns, edge case failures, and bad practices across Python, R, JavaScript/TypeScript, SQL, and front-end code. Scrutinizes error handling, type safety, performance, accessibility, and code quality. Provides structured feedback with severity tiers (Blocking, Required, Suggestions) and specific, actionable recommendations.
Pragmatic coding standards for writing clean, maintainable code — naming, functions, structure, anti-patterns, and pre-edit safety checks. Use when writing new code, refactoring existing code, reviewing code quality, or establishing coding standards.
Claude Code integration for OpenClaw. This skill provides interfaces to: - Query Claude Code documentation from https://code.claude.com/docs - Manage subagents and coding tasks - Execute AI-assisted coding workflows - Access best practices and common workflows Use this skill when users want to: - Get help with coding tasks - Query Claude Code documentation - Manage AI-assisted development workflows - Execute complex programming tasks
Plan, draft, version, and refine written content with enforced versioning and quality audits.
Use when writing tests, creating test strategies, or building automation frameworks. Invoke for unit tests, integration tests, E2E, coverage analysis, performance testing, security testing.