use futures_util::StreamExt;

#[tokio::main]
async fn main() -> eyre::Result<()> {
    let client: gotify::ClientClient = gotify::Client::new(
        &*std::env::var("GOTIFY_URL")?,
        std::env::var("GOTIFY_CLIENT_TOKEN")?,
    )?;
    let mut messages = client.stream_messages().await?;
    while let Some(result) = messages.next().await {
        let message = result?;
        println!("{message:#?}")
    }
    Ok(())
}