WebSocket Streaming

Real-time market data streaming via WebSocket connections.

---

Overview

WebSocket connections provide live updates for market prices, orderbook changes, and trade execution. Essential for real-time trading strategies.

---

Polymarket WebSocket

Connection

from moltmarket import WebSocketClient

ws = WebSocketClient(platform="polymarket")

# Subscribe to market updates
ws.subscribe_market("0x1a2b3c...")

# Handle updates
@ws.on_update
def handle_update(data):
    print(f"Price: {data['price']}")
    print(f"Volume: {data['volume']}")

Message Types

{
  "type": "orderbook_update",
  "market_id": "0x1a2b3c...",
  "timestamp": "2026-03-19T14:30:00Z",
  "bids": [[0.46, 25000], [0.45, 32000]],
  "asks": [[0.48, 18000], [0.49, 28000]]
}

---

Kalshi WebSocket

Connection

ws = WebSocketClient(platform="kalshi")
ws.subscribe_market("KXRATE-24MAR29")

@ws.on_trade
def handle_trade(data):
    print(f"Trade: {data['side']} @ {data['price']}")

---

Best Practices

1. Reconnect on disconnect - Auto-handled by MoltMarket

2. Throttle updates - Don't process every tick

3. Monitor latency - WebSocket ping/pong

---

Related Documentation

• Polymarket - Platform integration

• Kalshi - Platform integration