Getting it into your agent
One page per mod, every tool's command on it. A separate URL per tool would split the same page into five that compete with each other.
npx skills add sawrus/agent-guides --skill streaming-patternsgit clone --depth 1 https://github.com/sawrus/agent-guidesWrote this? Show the measurements
A badge with what this costs and how it scanned, read live from this page, so it follows the numbers instead of freezing them. Markdown for a README, HTML for a documentation site or a project page.
[](https://agentmods.dev/skills/sawrus/agent-guides/streaming-patterns)<a href="https://agentmods.dev/skills/sawrus/agent-guides/streaming-patterns"><img src="https://agentmods.dev/badge/skills/sawrus/agent-guides/streaming-patterns/github.svg" alt="Measured on agentmods" height="20"></a>Or the 80×15 button, for a site that already has a row of RSS and ATOM ones. Only the verdict fits; the numbers stay here.
<a href="https://agentmods.dev/skills/sawrus/agent-guides/streaming-patterns"><img src="https://agentmods.dev/badge/skills/sawrus/agent-guides/streaming-patterns.svg" alt="Reviewed on agentmods" width="80" height="20"></a>- NVIDIA SkillSpector pass
What it costs to keep this loaded
Counted locally with the o200k_base tokenizer, which is exact for GPT models; Claude uses its own tokenizer and its counts differ. Treat this as one consistent yardstick across the catalogue rather than a bill. Prices are per million input tokens.
| Model | Per session | Once invoked |
|---|---|---|
| Fable 5.1 | $0.00034 | $0.00339 |
| Opus 5.5 | $0.00014 | $0.00136 |
| Sonnet 5.5 | $0.00007 | $0.00068 |
| Haiku 4.5 | $0.00003 | $0.00034 |
Grade A, and why
streaming-patterns scanned grade A with 0 findings against 26 rules in 11 categories — prompt injection, anti-refusal, data exfiltration, privilege escalation, supply chain, agent snooping, system-prompt leakage, SSRF and excessive agency — measured 3d ago.
A static scan of the body, not an audit. Every finding is printed with the line that produced it so you can judge whether it matters here. A mod is markdown that instructs an agent; that is exactly why what it instructs is worth reading.
Nothing flagged
None of the 26 patterns this scan looks for appear in this file: no shell pipes, no recursive deletes, no credential paths, no hidden text, no instruction-override or anti-refusal phrasing, no agent-config snooping. That is not a guarantee, it is the absence of the things that are checkable.
What it actually says
Skill: Streaming Data Patterns
When to load
When designing Kafka consumers/producers or implementing real-time pipelines.
Producer Best Practices
producer = Producer({
"bootstrap.servers": settings.KAFKA_BROKERS,
"acks": "all", # Wait for all replicas
"retries": 5,
"enable.idempotence": True, # Exactly-once delivery
"compression.type": "snappy",
})
Consumer Pattern
consumer = Consumer({
"group.id": "order-processor-v1", # Version when changing logic
"auto.offset.reset": "earliest",
"enable.auto.commit": False, # Manual commit: only after successful processing
})
msg = consumer.poll(timeout=1.0)
try:
process(deserialize(msg.value()))
consumer.commit(msg) # Commit only after success
except ProcessingError as e:
publish_to_dlq(msg, e) # Dead-letter, don't block partition
consumer.commit(msg)
Dead Letter Queue
{
"original_topic": "orders.created.v1",
"original_offset": 12345,
"original_payload": "...",
"error_message": "Deserialization failed",
"error_timestamp": "2026-02-16T10:30:00Z",
"retry_count": 3
}
What this file has done since we first saw it
Hashed on every crawl. A supply-chain change to an agent config is a question of when, not whether, so the history is kept rather than the latest state alone.
- 3d ago Changed · +5 lines · +34 tokens per session 2e0fffc7d3e8
- 1mo ago First seen · 49 lines · 0 tokens per session scan A c96fd4bf3e42
streaming-patterns is a skill published in the GitHub repository sawrus/agent-guides (19 stars, last pushed yesterday), licensed MIT. It adds 34 tokens to every session and 339 once invoked, about $0.0001 per session on Opus 5.5. A static security scan graded it A with 0 findings. No closer match exists in the catalogue, so it is treated as the original; first seen 2026-08-30.
Other skills, from other repositories
gemini-api-dev
The Gemini API provides access to Google's most advanced AI models. Key capabilities include.
gemini-api-integration
Use when integrating Google Gemini API into projects. Covers model selection, multimodal inputs, streaming, function calling, and production best practices.
gemini-interactions-api
Use this skill when writing code that calls the Gemini API for text generation, multi-turn chat, multimodal understanding, image generation, video generation, streaming responses, background research tasks, function calling, structured output, or migrating from the old generateContent API. This skill covers the…
gemini-live-api-dev
Use this skill when building real-time, bidirectional streaming applications with the Gemini Live API. Covers WebSocket-based audio/video/text streaming, voice activity detection (VAD), native audio features, function calling, session management, ephemeral tokens for client-side auth, live translation, and all Live…
gemini-api-dev
Use this skill when building applications with Gemini API hosted models, including Gemini and Gemma 4, working with multimodal content (text, images, audio, video), implementing function calling, using structured outputs, or needing current model specifications. Covers SDK usage (google-genai for Python, @google/genai…
semantic-search
Professional Semantic Search Expert skill. Build performant, secure, and scalable backend logic and RESTful or GraphQL APIs.