ticksupply 0.1.0

Official Rust client for the Ticksupply market data API
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

//! Stream subscription list with error handling and early termination.
//!
//! Run: `TICKSUPPLY_API_KEY=... cargo run --example streaming_subscriptions`

use futures::StreamExt;

#[tokio::main]
async fn main() -> ticksupply::Result<()> {
    let client = ticksupply::Client::new()?;
    let stream = client.subscriptions().list().limit(10).stream();
    tokio::pin!(stream);
    let mut count = 0;
    while let Some(item) = stream.next().await {
        match item {
            Ok(sub) => {
                count += 1;
                println!("{:3}: {} [{:?}]", count, sub.id, sub.status);
                if count >= 25 {
                    println!("stopping at 25");
                    break;
                }
            }
            Err(e) => {
                eprintln!("stream error: {e}");
                break;
            }
        }
    }
    Ok(())
}