irtt-client 0.5.2

IRTT-compatible Rust client library
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
47
48
49
50
51
52
53
54

use super::*;

#[test]
fn recv_available_drains_burst_replies() {
    let params = default_params();
    let (mut client, server) = open_client_with_echo_server(&params);

    client.send_probe().unwrap();
    client.send_probe().unwrap();
    client.send_probe().unwrap();
    thread::sleep(Duration::from_millis(80));

    let events = client
        .recv_available(RecvBudget { max_packets: 8 })
        .unwrap();
    assert_eq!(events.len(), 3);
    for (seq, event) in events.iter().enumerate() {
        assert!(matches!(
            event,
            ClientEvent::EchoReply {
                seq: actual_seq,
                ..
            } if *actual_seq == seq as u32
        ));
    }

    client.close().unwrap();
    server.join();
}

#[test]
fn recv_available_respects_packet_budget() {
    let params = default_params();
    let (mut client, server) = open_client_with_echo_server(&params);

    client.send_probe().unwrap();
    client.send_probe().unwrap();
    thread::sleep(Duration::from_millis(80));

    let first = client
        .recv_available(RecvBudget { max_packets: 1 })
        .unwrap();
    assert_eq!(first.len(), 1);
    assert!(matches!(&first[0], ClientEvent::EchoReply { seq: 0, .. }));

    let second = client
        .recv_available(RecvBudget { max_packets: 8 })
        .unwrap();
    assert_eq!(second.len(), 1);
    assert!(matches!(&second[0], ClientEvent::EchoReply { seq: 1, .. }));

    client.close().unwrap();
    server.join();
}