Real-Time Data
Built for What's Next.
ClawXP is the open-source pub/sub protocol your WebSocket setup wishes it was. HTTP/3 native. Automatic fallback. Ships in minutes.
The real-time backbone powering OpenClaw - and your next production app.
Quick Install
Built for demanding real-time workloads
ClawXP delivers sub-millisecond message latency using HTTP/3 and QUIC, with automatic fallback to WebSocket when UDP is blocked.
Streams for truth
Reliable ordered delivery over QUIC streams. Critical messages arrive intact, in order, with backpressure control.
Datagrams for speed
Unreliable fast delivery for price feeds and telemetry. Freshness tracking drops stale updates automatically.
Auto fallback
UDP blocked? No problem. SDK detects unavailable WebTransport and falls back to WebSocket with the same API.
Horizontal scale
In-memory adapter by default. Swap in the Redis adapter for cross-node fan-out with one config line.
How it works
WebTransport over QUIC as primary path. WebSocket as automatic fallback. Same developer API either way.
Powering OpenClaw's live agent streams
OpenClaw - the AI that manages your inbox, emails, calendar, and flights - uses ClawXP as its real-time pub/sub backbone. Every agent reasoning step, tool call, and completion event flows through ClawXP.
- Subscribe to live agent reasoning steps
- Stream tool execution events (browse, email, calendar)
- Receive task completion summaries
- Datagram mode for high-frequency status heartbeats
import { ClawXPClient } from '@clawxp/sdk';
const client = new ClawXPClient({
url: 'wss://your-clawxp-server.com',
token: process.env.CLAWXP_TOKEN,
});
// Live agent reasoning steps
await client.subscribe('openclaw:agent-stream', {
mode: 'stream',
onMessage: (msg) => {
const { thought, step } = msg.data;
ui.appendThought(thought, step);
},
});
// High-frequency status (datagram)
await client.subscribe('openclaw:status', {
mode: 'datagram',
onMessage: (msg) => {
updateIndicator(msg.data.state);
// 'thinking' | 'idle' | 'waiting'
},
});Built for any real-time workload
DeFi price feeds
Tick-by-tick updates with datagram mode. Sequence numbers prevent showing stale quotes.
Live dashboards
System telemetry and analytics. Subscribe to thousands of metric channels simultaneously.
AI agent streams
Stream LLM reasoning steps, tool calls, and model output as they happen.
Multiplayer state
Game state, collaborative editors, and real-time maps with reliable ordered streams.
Ready to ship real-time?
Install the SDK and connect to your first channel in minutes. MIT licensed. No vendor lock-in.