radion-sdk 0.9.0

Official, async-first, fully-typed Rust SDK for the Radion platform
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! Connect, subscribe to trades, and print typed events.
//!
//! ```sh
//! RADION_API_KEY=sk_... cargo run --example quickstart
//! ```

use futures_util::StreamExt;
use radion_sdk::Radion;
use radion_sdk::realtime::{Channel, Payload, Subscription};

#[tokio::main]
async fn main() -> eyre::Result<()> {
    let api_key = std::env::var("RADION_API_KEY").expect("set RADION_API_KEY");
    let radion = Radion::builder().api_key(api_key).build()?;

    radion.realtime.connect().await?;

    let mut trades = radion
        .realtime
        .subscribe(Subscription::new("trading", Channel::Trading))
        .await?;

    while let Some(event) = trades.next().await {
        match event.data {
            Payload::Trading(trade) => println!("{} {:?}", event.id, trade.kind),
            other => println!("{} {other:?}", event.id),
        }
    }

    Ok(())
}