redpine 0.3.0

Connection-oriented UDP data transfer for real-time applications
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

static EVENT_TIMEOUT: std::time::Duration = std::time::Duration::from_millis(1000);

fn main() {
    let config = redpine::ClientConfig {
        handshake_timeout_ms: 4_000,
        connection_timeout_ms: 4_000,
        ..Default::default()
    };

    let mut client = redpine::Client::connect_with_config(("127.0.0.1", 8888), config)
        .expect("failed to create redpine client");

    loop {
        client.send(
            vec![0x00, 0x01, 0x02].into(),
            redpine::SendMode::Unreliable(0),
        );

        while let Some(event) = client.wait_event_timeout(EVENT_TIMEOUT) {
            match event {
                redpine::ClientEvent::Connect => {
                    println!("ClientEvent::Connect");
                }
                redpine::ClientEvent::Disconnect => {
                    println!("ClientEvent::Disconnect");
                }
                redpine::ClientEvent::Receive(packet_bytes) => {
                    println!("ClientEvent::Receive {packet_bytes:02X?}");
                }
                redpine::ClientEvent::Error(kind) => match kind {
                    redpine::ErrorKind::Timeout => {
                        println!("ClientEvent::Error(redpine::ErrorKind::Timeout)");
                    }
                    redpine::ErrorKind::Capacity => {
                        println!("ClientEvent::Error(redpine::ErrorKind::Capacity)");
                    }
                    redpine::ErrorKind::Parameter => {
                        println!("ClientEvent::Error(redpine::ErrorKind::Parameter)");
                    }
                },
            }
        }

        // println!("no event after {}ms", EVENT_TIMEOUT.as_millis());
    }
}