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
32
33
34
35
36
37
38
39
40
41
42

//! Observe connection lifecycle events alongside channel data.
//!
//! ```sh
//! RADION_API_KEY=sk_... cargo run --example lifecycle
//! ```

use futures_util::StreamExt;
use radion_sdk::Radion;
use radion_sdk::realtime::{Channel, LifecycleEvent, 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()?;

    // Watch lifecycle events on a background task.
    let mut lifecycle = radion.realtime.lifecycle();
    tokio::spawn(async move {
        while let Some(event) = lifecycle.next().await {
            match event {
                LifecycleEvent::Open => println!("open"),
                LifecycleEvent::Close { code, reason } => println!("close {code} {reason}"),
                LifecycleEvent::Reconnect { attempt, delay } => {
                    println!("reconnect #{attempt} in {delay:?}");
                }
                LifecycleEvent::Error(error) => eprintln!("error: {error}"),
                _ => {}
            }
        }
    });

    radion.realtime.connect().await?;
    let mut events = radion
        .realtime
        .subscribe(Subscription::new("trading", Channel::Trading))
        .await?;
    while let Some(event) = events.next().await {
        println!("{}: {:?}", event.channel, event.data);
    }

    Ok(())
}