From a2a-multi-agent
Implements A2A SSE streaming via message/stream for real-time task status and artifact updates, including TaskStatusUpdateEvent, TaskArtifactUpdateEvent, and re-subscription in agents.
npx claudepluginhub orcaqubits/agentic-commerce-skills-plugins --plugin a2a-multi-agentThis skill is limited to using the following tools:
**Fetch live docs**:
Acquire memory dumps from live systems/VMs and analyze with Volatility 3 for processes, networks, DLLs, injections in incident response or malware hunts.
Provides x86-64/ARM disassembly patterns, calling conventions, control flow recognition for static analysis of executables and compiled binaries.
Identifies anti-debugging checks like IsDebuggerPresent, NtQueryInformationProcess in Windows binaries; suggests bypasses via patches/hooks/scripts for malware analysis, CTFs, authorized RE.
Fetch live docs:
https://a2a-protocol.org/latest/specification/ for the streaming sectionsite:github.com a2aproject A2A streaming SSE message/stream for streaming protocol detailssite:github.com a2aproject a2a-samples streaming for streaming implementation examplesA2A streaming uses Server-Sent Events (SSE) to deliver real-time task updates from server to client. Instead of waiting for the entire task to complete (message/send), the client receives incremental updates as the agent works (message/stream).
message/stream (same payload as message/send)Content-Type: text/event-stream| Event Type | Purpose | When Sent |
|---|---|---|
| TaskStatusUpdateEvent | Task state changed | On every state transition |
| TaskArtifactUpdateEvent | New artifact data | When agent produces output |
SSE events follow the standard format:
event: <event-type>
data: <JSON payload>
Each event's data field contains a JSON object with:
If the SSE connection drops, the client can re-subscribe:
tasks/resubscribe with the taskIdThe server must:
streaming: true in the Agent Card capabilitiesmessage/stream methodThe client must:
streaming capabilitymessage/stream instead of message/send:keepalive\n\n) to prevent proxy timeoutsFetch the specification for exact SSE event schemas, event naming conventions, and re-subscription protocol before implementing.