use binance_client_ws::{api::subscribe::Levels, client::Client};
use futures::StreamExt;

#[tokio::main]
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);
    }
}