use bitstamp_ws_client::Client;
use futures::StreamExt;

#[tokio::main]
async fn main() {
    let mut client = Client::connect_public().await.expect("cannot connect");

    client.subscribe_live_orderbook("btcusd").await;

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

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