Struct binance_client_ws::client::Client

pub struct Client {
    pub broadcast: Option<Sender<String>>,
    pub depth_events: Option<Pin<Box<dyn Stream<Item = DepthEvent> + Send + Sync>>>,
    /* private fields */
}

A WebSocket client for Binance.

Fields

broadcast: Option<Sender<String>>

depth_events: Option<Pin<Box<dyn Stream<Item = DepthEvent> + Send + Sync>>>

Implementations

impl Client

pub async fn subscribe_depth(&mut self, symbol: &str, levels: Levels)

Examples found in repository

examples/book.rs (line 8)

async fn main() {
    let mut client = Client::connect_market_data().await.expect("cannot connect");

    client.subscribe_depth("btcusdt", Levels::L10).await;

    let mut depth_events = client.depth_events.unwrap();

    while let Some(msg) = depth_events.next().await {
        dbg!(&msg);
    }
}

impl Client

pub async fn connect(url: &str) -> Result<Self>

pub async fn connect_market_data() -> Result<Self>

Examples found in repository

examples/book.rs (line 6)

async fn main() {
    let mut client = Client::connect_market_data().await.expect("cannot connect");

    client.subscribe_depth("btcusdt", Levels::L10).await;

    let mut depth_events = client.depth_events.unwrap();

    while let Some(msg) = depth_events.next().await {
        dbg!(&msg);
    }
}

pub async fn send<R>(&mut self, req: R) -> Result<()>where R: Serialize,

Sends a message to the WebSocket.

pub async fn call<P>( &mut self, method: impl Into<String>, params: P ) -> Result<()>where P: Serialize,

Performs a remote procedure call.