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

use std::sync::Arc;
use std::time::Instant;

use super::*;

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

    let waker = Arc::clone(&signal);
    tokio::spawn(async move {
        tokio::time::sleep(Duration::from_millis(20)).await;
        waker.request();
    });

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

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

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

    tokio::time::timeout(Duration::from_secs(5), signal.wait())
        .await
        .expect("latched request must not block");
}

#[tokio::test]
async fn sleep_expires_without_a_request() {
    let signal = ShutdownSignal::default();

    signal.sleep(Duration::from_millis(10)).await;

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