Rust

cargo add openpx

cargo add tokio --features full
cargo add serde_json

use openpx::ExchangeInner;
use serde_json::json;

let ex = ExchangeInner::new("polymarket", json!({
    "private_key": std::env::var("POLYMARKET_PRIVATE_KEY")?,
    "funder": std::env::var("POLYMARKET_FUNDER")?,
}))?;

use openpx::{Kalshi, KalshiConfig, Polymarket, PolymarketConfig};

use openpx::WebSocketInner;
use px_core::websocket::OrderBookWebSocket;
use serde_json::json;
use futures::StreamExt;

let mut ws = WebSocketInner::new("polymarket", json!({}))?;
let mut updates = ws.updates().expect("first call");
let mut session = ws.session_events().expect("first call");

ws.connect().await?;
ws.subscribe("0x…token_id").await?;

while let Some(update) = updates.next().await {
    match update? {
        px_core::WsUpdate::Snapshot { book, .. } => { /* ... */ }
        px_core::WsUpdate::Delta { changes, .. } => { /* ... */ }
        px_core::WsUpdate::Trade { trade, .. } => { /* ... */ }
        px_core::WsUpdate::Fill { fill, .. } => { /* ... */ }
        px_core::WsUpdate::Clear { reason, .. } => { /* ... */ }
    }
}