aurpc 0.3.1

Asynchronous UDP RPCs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use aurpc::RpcSocket;

#[async_std::main]
async fn main() -> std::io::Result<()> {
    let socket = RpcSocket::bind("0.0.0.0:0").await?;

    let addr = socket.local_addr();
    println!("listening on: {:?}", addr);

    let mut buf = [0u8; 256];

    loop {
        let (bytes_read, responder) = socket.recv_from(&mut buf[..]).await?;
        responder.respond(&buf[..bytes_read]).await?;
    }
}