Struct PredictWebSocket 

pub struct PredictWebSocket { /* private fields */ }

WebSocket client for Predict.fun

Implementations

impl PredictWebSocket

pub fn new(ws_url: String) -> Self

Create a new PredictWebSocket client

pub async fn connect(&self) -> Result<PredictWsStream>

Connect to the WebSocket and return a message stream

The returned stream yields parsed WsMessage items. Heartbeat messages are handled automatically.

pub async fn subscribe_orderbook(&self, market_id: u64) -> Result<()>

Subscribe to orderbook updates for a market

pub async fn unsubscribe_orderbook(&self, market_id: u64) -> Result<()>

Unsubscribe from orderbook updates for a market

pub async fn subscribe_asset_price(&self, price_feed_id: &str) -> Result<()>

Subscribe to asset price updates for a price feed

The price_feed_id is typically a Pyth price feed ID (hex string). Common feeds:

• BTC/USD: 0xe62df6c8b4a85fe1a67db44dc12de5db330f7ac66b72dc658afedf0f4a415b43
• ETH/USD: 0xff61491a931112ddf1bd8147cd1b641375f79f5825126d665480874634fd0ace

pub async fn unsubscribe_asset_price(&self, price_feed_id: &str) -> Result<()>

Unsubscribe from asset price updates for a price feed

pub async fn subscribe_polymarket_chance(&self, market_id: u64) -> Result<()>

Subscribe to Polymarket chance updates for a market

Receives chance/price data from Polymarket for cross-platform comparison.

pub async fn subscribe_kalshi_chance(&self, market_id: u64) -> Result<()>

Subscribe to Kalshi chance updates for a market

Receives chance/price data from Kalshi for cross-platform comparison.

pub async fn subscribe_wallet_events(&self, jwt: &str) -> Result<()>

Subscribe to wallet events (order fills, cancellations, etc.)

Requires a JWT token obtained from PredictClient::authenticate(). Topic: predictWalletEvents/{jwt}

Events include:

• orderAccepted: Order placed in orderbook
• orderTransactionSuccess: Order filled on-chain
• orderCancelled: Order cancelled
• orderTransactionFailed: On-chain transaction failed

pub async fn unsubscribe_wallet_events(&self, jwt: &str) -> Result<()>

Unsubscribe from wallet events

pub async fn send_heartbeat(&self, timestamp: u64) -> Result<()>

Send a heartbeat response with the given timestamp

pub async fn reconnect(&self) -> Result<PredictWsStream>

Reconnect to the WebSocket server

Clears the old writer and establishes a fresh connection. Subscriptions must be re-sent after reconnecting.

pub fn config(&self) -> &WsConnectionConfig

Get the connection config (for backoff settings)

pub async fn is_connected(&self) -> bool

Check if connected

pub fn subscribed_markets(&self) -> Vec<u64>

Get list of subscribed market IDs

pub fn writer(&self) -> Arc<Mutex<Option<WsWriter>>>

Get a clone of the writer Arc for external heartbeat handling