ibapi 5.5.0

An unofficial Rust client for the Interactive Brokers TWS API: market data, orders, and account data, with async (Tokio) and blocking clients for TWS and IB Gateway.
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

//! Async stream retry example
//!
//! Streams realtime bars across reconnects with `Client::resubscribing`.
//!
//! # Usage
//!
//! ```bash
//! cargo run --example async_stream_retry
//! ```

use futures::StreamExt;
use ibapi::market_data::TradingHours;
use ibapi::prelude::*;
use ibapi::TRANSPORT_RECONNECT_CODE;

#[tokio::main]
async fn main() {
    env_logger::init();

    let client = Client::connect("127.0.0.1:4002", 100).await.expect("connection to TWS failed!");

    let contract = Contract::stock("AAPL").build();

    // Resubscribes after each reconnect; ends on any other error, or once the
    // client gave up reconnecting (ConnectionFailed) or was shut down (Shutdown).
    let bars = client.resubscribing(|| client.realtime_bars(&contract).trading_hours(TradingHours::Extended).subscribe());
    let mut bars = std::pin::pin!(bars);

    while let Some(item) = bars.next().await {
        match item {
            Ok(SubscriptionItem::Data(bar)) => println!("bar: {bar:?}"),
            Ok(SubscriptionItem::Notice(notice)) if notice.code == TRANSPORT_RECONNECT_CODE => {
                eprintln!("Resubscribed after a reconnect; bars from the outage are missing.")
            }
            Ok(SubscriptionItem::Notice(notice)) => eprintln!("notice: {notice}"),
            Err(e) => eprintln!("stream ended: {e}"),
        }
    }
}