Struct BybitWebSocket 

pub struct BybitWebSocket { /* private fields */ }

WebSocket client for Bybit streaming API.

Implementations

impl BybitWebSocket

pub fn public(url: &str) -> Self

Create a new public WebSocket client.

pub fn private(api_key: &str, api_secret: &str, url: &str) -> Self

Create a new private WebSocket client.

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

Connect to the WebSocket server.

pub async fn subscribe<F>( &mut self, topics: Vec<String>, callback: F, ) -> Result<()>

where F: Fn(WsMessage) + Send + Sync + 'static,

Subscribe to topics.

Arguments

• topics - List of topics to subscribe
• callback - Callback function for received messages

pub async fn unsubscribe(&mut self, topics: Vec<String>) -> Result<()>

Unsubscribe from topics.

pub async fn is_connected(&self) -> bool

Check if connected.

pub async fn disconnect(&mut self) -> Result<()>

Disconnect from the server.