kalshi-pmx 0.1.1

Async Rust client for Kalshi's Trade API and WebSocket streams.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

mod common;

use kalshi_pmx::ws::Subscription;

#[tokio::main]
async fn main() -> common::ExampleResult {
    let kalshi = common::authenticated_client()?;
    let ticker = common::required_env(&["KALSHI_TICKER"])?;

    let mut stream = kalshi.stream().connect().await?;
    stream
        .subscribe(Subscription::ticker().markets([ticker]))
        .await?;

    while let Some(message) = stream.next().await {
        println!("{:#?}", message?);
    }

    Ok(())
}