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

//! Stream Retry example
//!
//! Streams realtime bars across reconnects with `Client::resubscribing`.
//!
//! # Usage
//!
//! ```bash
//! cargo run --no-default-features --features sync --example stream_retry
//! ```

use ibapi::client::blocking::Client;
use ibapi::contracts::Contract;
use ibapi::market_data::TradingHours;
use ibapi::subscriptions::SubscriptionItem;
use ibapi::TRANSPORT_RECONNECT_CODE;

fn main() {
    env_logger::init();

    let connection_url = "127.0.0.1:4002";
    let client = Client::connect(connection_url, 100).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());

    for item in bars {
        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}"),
        }
    }
}