forky-udpflow

Crates.ioforky-udpflow
lib.rsforky-udpflow
version0.2.0
sourcesrc
created_at2023-06-03 09:54:16.34033
updated_at2023-06-07 20:41:01.734884
descriptionStream API for tokio-udp.
homepage
repositoryhttps://github.com/sabify/udpflow
max_upload_size
id881518
size45,881
Saber Haj Rabiee (sabify)

documentation

https://docs.rs/udpflow

README

UDPflow

crates.io Released API docs

Stream API for tokio-udp.

TCP-like UDP stream

use tokio::net::UdpSocket;
use tokio::io::{AsyncReadExt, AsyncWriteExt};
use udpflow::{UdpListener, UdpStreamLocal, UdpStreamRemote};
async fn server() {
    let addr = "127.0.0.1:5000".parse().unwrap();
    let listener = UdpListener::new(addr).unwrap();
    loop {
        let mut buf = vec![0u8; 0x2000];
        let (n, stream, addr) = listener.accept(&mut buf).await.unwrap();
        buf.truncate(n);
        tokio::spawn(handle(stream, buf));
    }
}

async fn handle(mut stream1: UdpStreamLocal, first_packet: Vec<u8>) {
    let local = "127.0.0.1:0".parse().unwrap();
    let remote = "127.0.0.1:10000".parse().unwrap();
    let mut stream2 = UdpStreamRemote::new(local, remote).await.unwrap();
    stream2.write_all(&first_packet).await.unwrap();
    let mut buf = vec![0u8; 256];
    stream1.read(&mut buf).await; stream2.write(&buf).await;
    stream2.read(&mut buf).await; stream1.write(&buf).await;
}

Send/Recv framed data

use tokio::net::TcpStream;
use udpflow::UotStream;
use tokio::io::{AsyncReadExt, AsyncWriteExt};
async {
    let stream = TcpStream::connect("127.0.0.1:8080").await.unwrap();
    let mut stream = UotStream::new(stream);
    let mut buf = vec![0u8; 256];
    // read a frame
    let n = stream.read(&mut buf).await.unwrap();
    // write a frame
    stream.write_all(&buf[..n]).await;
};

UoT Specification

+------+----------+
| LEN  |   DATA   |
+------+----------+
|  2   | Variable |
+------+----------+

*LEN is a 16-bit unsigned integer in big endian byte order.

Commit count: 45

cargo fmt