udx 0.2.0

Rust port of libudx, a protocol for reliable, multiplex, and congestion controlled streams over udp
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

use std::io;
use tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};
use udx::UdxSocket;

#[tokio::main]
async fn main() -> io::Result<()> {
    tracing_subscriber::fmt::init();

    // Bind two sockets
    let socka = UdxSocket::bind("127.0.0.1:20004")?;
    let addra = socka.local_addr()?;
    eprintln!("Socket A bound to {addra}");
    let sockb = UdxSocket::bind("127.0.0.1:20005")?;
    let addrb = sockb.local_addr()?;
    eprintln!("Socket B bound to {addrb}");

    // On each socket, create a stream connected to the other socket.
    let streama = socka.connect(addrb, 1, 1)?;
    let streamb = sockb.connect(addra, 1, 1)?;

    // Spawn a task that writes data from A to B.
    let count = 16;
    let write_task = tokio::spawn({
        let mut streama = streama.clone();
        async move {
            for i in 0..count {
                let message = format!("hello from udx! this is message no. {}\n", i);
                streama.write_all(message.as_bytes()).await?;
            }
            Ok::<_, io::Error>(())
        }
    });

    // Read incoming data on the other end, line by line.
    let mut reader = BufReader::new(streamb.clone());
    for _i in 0..count {
        let mut buf = String::new();
        let _n = reader.read_line(&mut buf).await?;
        eprintln!("recv: {}", &buf[..buf.len() - 1]);
    }

    // Wait a bit so that all acks are processed.
    tokio::time::sleep(std::time::Duration::from_millis(100)).await;
    eprintln!("stats stream A {:#?}", streama.stats());
    eprintln!("stats stream B {:#?}", streamb.stats());
    eprintln!("stats socket A {:#?}", socka.stats());
    eprintln!("stats socket B {:#?}", sockb.stats());
    write_task.await??;
    Ok(())
}