utp-socket 0.1.0

Socket used for uTP communication with io-uring support
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::time::Duration;

use utp_socket::utp_socket::UtpSocket;

#[test]
#[ignore = "Flakey on ci"]
fn end_to_end() {
    let _ = env_logger::builder()
        .filter_level(log::LevelFilter::Trace)
        .is_test(true)
        .try_init();
    std::thread::scope(|scope| {
        scope.spawn(|| {
            tokio_uring::start(async move {
                let socket = UtpSocket::bind("127.0.0.1:1337".parse().unwrap())
                    .await
                    .unwrap();
                println!("Bound sender");
                let stream = tokio::time::timeout(
                    Duration::from_secs(3),
                    socket.connect("127.0.0.1:1338".parse().unwrap()),
                )
                .await
                .unwrap()
                .unwrap();

                stream.write(b"Hello world!".to_vec()).await.unwrap();
            });
        });
        scope.spawn(|| {
            tokio_uring::start(async move {
                let socket = UtpSocket::bind("127.0.0.1:1338".parse().unwrap())
                    .await
                    .unwrap();
                println!("Bound Receiver");
                let stream = socket.accept().await.unwrap();
                let mut buf = vec![0u8; 256];
                let read = stream.read(&mut buf).await;
                assert_eq!(&buf[..read], b"Hello world!");
            });
        });
    });
}