continuum-streaming

continuum-streaming is a skill for Claude Code, Codex from shyftlabs/continuum. It costs 77 tokens per session (1,407 once invoked), scanned A, original, Apache-2.0.

Stream tokens, tool calls, handoffs, and memory events out of a Continuum agent in real time using runner.runstream() and the EventType enum. Invoke when the user asks "stream tokens to UI", "websocket chat", "live progress", "see tool execution as it happens", or anything that needs token-by-token output.

Skill for Claude CodeCodex

Install

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.

agentmods
npx agentmods add skills/shyftlabs/continuum/continuum-streaming
Any agent
npx skills add shyftlabs/continuum --skill continuum-streaming
Clone the repo
git clone --depth 1 https://github.com/shyftlabs/continuum

Made for: Claude Code, Codex.

Wrote 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.

agentmods badge for continuum-streaming

README.md
[![agentmods](https://agentmods.dev/badge/skills/shyftlabs/continuum/continuum-streaming.svg)](https://agentmods.dev/skills/shyftlabs/continuum/continuum-streaming)
Your own site
<a href="https://agentmods.dev/skills/shyftlabs/continuum/continuum-streaming"><img src="https://agentmods.dev/badge/skills/shyftlabs/continuum/continuum-streaming.svg" alt="Measured on agentmods" height="20"></a>
Per session 77 Skills are progressive disclosure: only the name and description are preloaded; the body loads when the skill is used.
When invoked 1,407 The whole file, excluding the scripts and references it only reads on demand.
Security scan A 0 findings. Scan, not verified.
Origin unknown No closer match found in the catalogue.
Token cost

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.

ModelPer sessionOnce invoked
Fable 5 $0.00077 $0.01407
Opus 5 $0.00039 $0.00704
Sonnet 5 $0.00015 $0.00281
Haiku 4.5 $0.00008 $0.00141

Measured today against content hash 241577bb9e60, method: parsed. Prices are Anthropic first-party input rates as of 2026-08-30, from the pricing page.

Security

Grade A, and why

continuum-streaming 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 today.

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.

.claude/skills/continuum-streaming/SKILL.md · 150 lines

How it starts

The opening of the file, as written. The whole thing — 150 lines — stays where its author put it; the contents beside it link to each section on GitHub.

Continuum Streaming Skill

Authoritative sources: docs/agent.md §3 and the EventType enum in continuum/agent/types.py.


Imports

from continuum.agent import AgentRunner
from continuum.agent.types import EventType, AgentEvent

Smallest possible stream

runner = AgentRunner()

async for ev in runner.run_stream(agent, "Tell me a story", user_id="u1", session_id="s1"):
    if ev.type == EventType.CONTENT_DELTA:
        print(ev.data["content"], end="", flush=True)

run_stream() returns an AsyncIterator[AgentEvent]. Every event carries: type: EventType, agent_name: str, run_id: str, data: dict, timestamp, trace_id, span_id.


Full event reference

EventType Fires event.data keys
RUN_START Run begins agent_name, input_preview
RUN_END Run completes status, latency_ms, usage
RUN_ERROR Run fails error, error_type
AGENT_START Each agent (incl. handoff target) starts agent_name
AGENT_END Each agent ends agent_name, status
CONTENT_DELTA LLM token chunks content (partial text)
CONTENT_COMPLETE LLM emits a full assistant message content
TOOL_CALL_START A tool is about to run tool_name, arguments
TOOL_CALL_END Tool returned successfully tool_name, result
TOOL_CALL_ERROR Tool raised tool_name, error
HANDOFF_START Source agent invoking the handoff tool from_agent, to_agent, reason
HANDOFF_END Target agent finished from_agent, to_agent
HANDOFF_RETURN Control returned to source (return_to_parent=True) from_agent, to_agent
MEMORY_RETRIEVAL Long-term memories injected into prompt count, query
MEMORY_STORAGE New memories stored after the turn count
WORKFLOW_STEP Workflow agent advanced step, agent_name
LOOP_ITERATION LoopAgent completed an iteration iteration, output

Read the full file on GitHub · 150 lines

Changes

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.

  1. today First seen · 150 lines · 77 tokens per session scan A 241577bb9e60

Subscribe to this mod's changes

continuum-streaming is a skill published in the GitHub repository shyftlabs/continuum (84 stars, last pushed today), licensed Apache-2.0. It adds 77 tokens to every session and 1,407 once invoked, about $0.0004 per session on Opus 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-09-03.

Related

Other skills, from other repositories

agenticx-memory-architect

Guide for setting up and using the AgenticX memory system including Mem0 integration, long-term memory, context management, and memory-enhanced agents. Use when the user wants to add memory to agents, persist conversation history, build memory-aware workflows, or integrate with Mem0 for long-term recall.

DemonDamon/AgenticX · 67 tokens

preferences-memory

Use memory tools only when the user explicitly wants a stable fact or preference remembered beyond the current conversation.

Threat-Vector-Security/guardian-agent · 0 tokens

hive.note-taking

Maintain a free-form scratchpad of decisions, extracted values, and open questions so context pruning doesn't lose anything you still need.

aden-hive/hive · 30 tokens

product-help

Use this skill when the user asks about my own features, configuration, or usage — installation, skills, Web UI, CLI, API config, memory, sessions, encryption, white-label, publishing, pricing, troubleshooting, or restarting the server. Do NOT trigger for general coding tasks unrelated to me.

clacky-ai/openclacky · 63 tokens

team-builder-packaging

Use when generating or auditing a multi-role agent team package with orchestrator, PM Soul, Memory Curator, Policy Gate, workers, eval, QA, handoffs, and runtime adapters.

agentlas-ai/Agentlas-OS · 43 tokens

workflow-ai-coding

Edit, validate, debug, publish, and inspect ReachAI Workflow drafts through the Workflow AI Coding REST API. Use when asked to create or modify a workflow graph, add/update/delete nodes or edges, validate GraphSpec, dry-run or debug-run a workflow, inspect trace/run output, check release readiness, publish a validated…

w8123/EnterpriseAgentFramework · 85 tokens