golang-samber-ro
Build Reactive Go Pipelines with samber/ro
Asynchronous Go pipelines can become difficult to compose, cancel, and test. This skill guides reliable samber/ro designs with typed operators and lifecycle controls.
Install with my Agent
Copy this request to your Agent. It includes the canonical Skill page and manifest.
Review the Skillstore skill "golang-samber-ro" from https://skillstore.io/skills/samber-golang-samber-ro.md and its manifest at https://skillstore.io/api/skills/samber-golang-samber-ro/manifest. Verify the artifact. You may proceed after verification, subject to the environment's own policy.Your Agent should still show its plan and request any confirmation required by the security policy.
Agent-readable resources
Use these links when an AI agent, crawler, or script needs clean context instead of reading the full page.
Test it
Using "golang-samber-ro". Choose an operator for parsing JSON events while propagating parse failures.
Expected outcome:
Recommendation: use MapErr with a parsing function that returns a value and an error. Handle failures in the observer error callback.
Using "golang-samber-ro". Five subscribers must connect before a shared source begins emitting.
Expected outcome:
- Use a Connectable observable instead of Share.
- Register every subscriber before starting the connection.
- Define cancellation and completion behavior for the shared source.
Using "golang-samber-ro". Review an infinite stream that has no timeout or unsubscribe path.
Expected outcome:
Risk: the subscription can outlive its owner and retain resources. Add context cancellation, a terminating operator, and an explicit cleanup test.
Security Audit
SafeAll 77 static findings are contextual false positives caused by Markdown backticks, ordinary Go examples, scoped tool declarations, and documentation links. No prompt injection, covert execution, reconnaissance, credential access, or data-exfiltration intent was found.
Risk Factors
โ๏ธ External commands (50)
๐ Network access (6)
Share & cite this report
Share the versioned assessment report, neutral badge, embed card, and citations. Skillstore reports evidence without deciding whether this Skill is safe.
Copy report link
https://skillstore.io/skills/samber-golang-samber-ro/audits/1?utm_source=security_passport&utm_medium=share&utm_campaign=versioned_reportMarkdown badge
[](https://skillstore.io/skills/samber-golang-samber-ro?utm_source=security_passport_badge)HTML badge
<a href="https://skillstore.io/skills/samber-golang-samber-ro?utm_source=security_passport_badge"><img src="https://skillstore.io/badges/skills/samber-golang-samber-ro/security.svg" alt="Skillstore security assessment" loading="lazy"></a>Embed card
<iframe src="https://skillstore.io/embed/skills/samber-golang-samber-ro.html" title="Skillstore Security Assessment" sandbox="allow-popups allow-popups-to-escape-sandbox" loading="lazy" referrerpolicy="no-referrer" width="420" height="180"></iframe>Academic citations (APA ยท BibTeX ยท CFF)
APA citation
samber. (2026). golang-samber-ro security audit report (audit version 1) [Author version 1.2.2]. Skillstore. https://skillstore.io/skills/samber-golang-samber-ro/audits/1BibTeX citation
@techreport{samber-samber-golang-samber-ro-2026,
author = {samber},
title = {golang-samber-ro security audit report (audit version 1)},
institution = {Skillstore},
year = {2026},
number = {1},
url = {https://skillstore.io/skills/samber-golang-samber-ro/audits/1},
note = {Author version 1.2.2}
}CITATION.cff
cff-version: 1.2.0
message: "If you use this Skill, cite its author and this versioned security audit report."
title: "golang-samber-ro security audit report (audit version 1)"
version: "1.2.2"
type: report
authors:
- name: "samber"
date-released: "2026-09-23"
url: "https://skillstore.io/skills/samber-golang-samber-ro/audits/1"
identifiers:
- type: other
value: "skillstore:samber-golang-samber-ro:audit:1"
description: "Skillstore immutable audit report identifier"
Skillstore Score
Why this score Evidence Confidence: MediumWhat You Can Build
Design an event pipeline
Choose operators, cancellation, and error handling for a service that processes asynchronous events.
Review reactive architecture
Assess hot and cold stream choices, subscription lifecycles, and resource cleanup before production deployment.
Learn samber/ro patterns
Translate channel-based workflows into typed observables while understanding subjects, composition, retries, and completion.
Try These Prompts
Build a samber/ro pipeline from [source]. Filter [condition], transform each value into [type], collect the results, and explain error handling.
Design a samber/ro pipeline for [operation]. Add context cancellation, a [duration] timeout, [count] bounded retries, and a final fallback.
Compare cold, Share, ShareReplay, Connectable, and subjects for [event source]. Recommend one based on [subscriber behavior] and lifecycle requirements.
Review this samber/ro design: [description]. Find lifecycle, ordering, backpressure, concurrency, and error-propagation risks. Propose tests and a safer architecture.
Best Practices
- Handle next, error, and completion events explicitly for every production subscription.
- Prefer typed Pipe functions and bound infinite streams with cancellation or terminating operators.
- Use Tap operators for logging and metrics without changing stream values.
Avoid
- Do not use untyped Pipe when a typed Pipe function can preserve compile-time checks.
- Do not share a cold source unless subscribers require one coordinated execution.
- Do not leave infinite subscriptions without context cancellation, timeout, or explicit unsubscribe behavior.
Frequently Asked Questions
When should I use samber/ro instead of channels?
When should I use samber/lo instead?
Does the skill generate complete Go programs?
Can it help prevent goroutine leaks?
Does it cover samber/ro plugins?
Will every example match my installed version?
Developer Details
Author
samberLicense
MIT
Author version
v1.2.2
Skillstore revision
r1
Ref
2aa351cb09c29b7287d263bd8ea81e9bee3b2a61
Maintenance freshness
9/30/2026
Usage
0 downloads ยท 0 views
File structure
๐ evals/
๐ evals.json
๐ references/
๐ operators-guide.md
๐ patterns.md
๐ plugin-ecosystem.md
๐ subjects-guide.md
๐ SKILL.md