Struct WsClient 

pub struct WsClient { /* private fields */ }

WebSocket client for public and private streams.

Implementations

impl WsClient

pub async fn connect_public( channel: WsChannel, ) -> Result<(Self, UnboundedReceiver<WsMessage>), BybitError>

Create a new WebSocket client for public streams.

Example

use bybit_client::ws::{WsClient, WsChannel};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let (client, mut receiver) = WsClient::connect_public(WsChannel::PublicLinear).await?;

    client.subscribe(&["orderbook.50.BTCUSDT"]).await?;

    while let Some(msg) = receiver.recv().await {
        println!("Received: {:?}", msg);
    }

    Ok(())
}

pub async fn connect_private( api_key: impl Into<String>, api_secret: impl Into<String>, ) -> Result<(Self, UnboundedReceiver<WsMessage>), BybitError>

Create a new WebSocket client for private streams (requires authentication).

Example

use bybit_client::ws::{WsClient, WsChannel};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let (client, mut receiver) = WsClient::connect_private(
        "api_key",
        "api_secret",
    ).await?;

    client.subscribe(&["position", "order", "execution"]).await?;

    while let Some(msg) = receiver.recv().await {
        println!("Received: {:?}", msg);
    }

    Ok(())
}

pub async fn connect_with_config( config: ClientConfig, channel: WsChannel, ) -> Result<(Self, UnboundedReceiver<WsMessage>), BybitError>

Create a new WebSocket client with custom configuration.

pub async fn subscribe(&self, topics: &[&str]) -> Result<(), BybitError>

Subscribe to topics.

pub async fn unsubscribe(&self, topics: &[&str]) -> Result<(), BybitError>

Unsubscribe from topics.

pub fn is_connected(&self) -> bool

Check if the client is connected.

pub fn disconnect(&self)

Disconnect and stop the client.

pub async fn subscribed_topics(&self) -> Vec<String>

Get the list of subscribed topics.

pub fn channel(&self) -> WsChannel

Get the WebSocket channel.

Trait Implementations

impl Drop for WsClient

fn drop(&mut self)

Executes the destructor for this type.