Status

use futures::StreamExt;
use pangea_client::{ClientBuilder, WsProvider};
use std::sync::Arc;
 
#[tokio::main]
async fn main() {
    dotenvy::dotenv_override().ok();
 
    let client = match ClientBuilder::default()
        .endpoint("app.pangea.foundation")
        .build::<WsProvider>()
        .await
    {
        Ok(client) => Arc::new(client),
        Err(e) => {
            eprintln!("Client failed to initialize:\n{e}");
            return;
        }
    };
 
    let status = client.get_status().await.unwrap(); 
 
    futures::pin_mut!(status);
 
    while let Some(chunk) = status.next().await {
        println!("{:?}", chunk.unwrap());
    }
}