ibapi 4.1.0

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

use std::sync::Arc;
use std::thread;
use std::time::{Duration, Instant};

use super::*;

#[test]
fn wait_timeout_returns_when_shutdown_requested() {
    let signal = Arc::new(ShutdownSignal::default());
    assert!(!signal.is_requested());

    let waker = Arc::clone(&signal);
    thread::spawn(move || {
        thread::sleep(Duration::from_millis(20));
        waker.request();
    });

    let start = Instant::now();
    signal.wait_timeout(Duration::from_secs(30));

    assert!(signal.is_requested());
    assert!(start.elapsed() < Duration::from_secs(5), "wait_timeout did not return on request");
}

#[test]
fn wait_timeout_returns_immediately_when_already_requested() {
    let signal = ShutdownSignal::default();
    signal.request();

    let start = Instant::now();
    signal.wait_timeout(Duration::from_secs(30));

    assert!(start.elapsed() < Duration::from_secs(5), "latched request must not block");
}

#[test]
fn wait_timeout_expires_without_a_request() {
    let signal = ShutdownSignal::default();

    signal.wait_timeout(Duration::from_millis(10));

    assert!(!signal.is_requested());
}