ibapi 2.11.2

A Rust implementation of the Interactive Brokers TWS API, providing a reliable and user friendly interface for TWS and IB Gateway. Designed with a focus on simplicity and performance.
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
43
44
45
46

#![allow(clippy::uninlined_format_args)]
use ibapi::contracts::Contract;
use ibapi::Client;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    env_logger::init();

    // Connect to IB Gateway or TWS
    let client = Client::connect("127.0.0.1:4002", 100).await?;

    println!("=== Subscribing to Contract News ===");

    // Create a contract to monitor news for
    let contract = Contract::stock("AAPL").build();

    // Specify news providers to subscribe to (empty means all)
    let provider_codes = &["BRFG", "DJNL"];

    println!("Subscribing to news for {} from providers: {:?}", contract.symbol, provider_codes);

    let mut news_stream = client.contract_news(&contract, provider_codes).await?;

    println!("Waiting for news... (Press Ctrl+C to stop)");

    while let Some(result) = news_stream.next().await {
        match result {
            Ok(article) => {
                println!("\n--- Breaking News ---");
                println!("Time: {}", article.time);
                println!("Provider: {}", article.provider_code);
                println!("Article ID: {}", article.article_id);
                println!("Headline: {}", article.headline);
                if !article.extra_data.is_empty() {
                    println!("Extra data: {}", article.extra_data);
                }
            }
            Err(e) => {
                eprintln!("Error: {e:?}");
                break;
            }
        }
    }

    Ok(())
}