Struct WebSocketWithPing 

pub struct WebSocketWithPing { /* private fields */ }

WebSocket client with automatic ping handling.

Use this when you need automatic keep-alive pings. Call run to process messages with automatic ping handling.

Implementations

impl WebSocketWithPing

pub async fn run<F, Fut>(self, handler: F) -> Result<(), WebSocketError>

where F: FnMut(Channel) -> Fut, Fut: Future<Output = Result<(), WebSocketError>>,

Run the WebSocket message loop with automatic ping handling.

This method will:

• Send ping messages at the configured interval
• Call the provided handler for each received message
• Return when the connection is closed or an error occurs

Arguments

• handler - Async function called for each received channel message

Example

use polyte_clob::ws::{WebSocketBuilder, Channel};
use std::time::Duration;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let ws = WebSocketBuilder::new()
        .ping_interval(Duration::from_secs(10))
        .connect_market(vec!["asset_id".to_string()])
        .await?;

    ws.run(|msg| async move {
        println!("Received: {:?}", msg);
        Ok(())
    }).await?;

    Ok(())
}

pub fn channel_type(&self) -> ChannelType

Get the channel type this WebSocket is connected to.