Struct UdpStreamReadHalf 

pub struct UdpStreamReadHalf { /* private fields */ }

UdpStream read-side implementation

Implementations

impl UdpStreamReadHalf

pub async fn recv_datagram(&mut self) -> Result<Bytes>

Receive a single UDP datagram as an owned buffer.

Examples found in repository

examples/udp_datagram_echo.rs (line 16)

async fn main() -> Result<()> {
    let listener = UdpListener::bind("127.0.0.1:9000").await?;
    println!("udp datagram echo server listening on 127.0.0.1:9000");

    loop {
        let (stream, addr) = listener.accept().await?;
        println!("accepted udp peer: {addr}");

        tokio::spawn(async move {
            let (mut reader, writer) = stream.split();
            loop {
                let msg = match reader.recv_datagram().await {
                    Ok(msg) => msg,
                    Err(err) => {
                        println!("recv_datagram error: {err}");
                        return;
                    }
                };
                if let Err(err) = writer.send_datagram(&msg).await {
                    println!("send_datagram error: {err}");
                    return;
                }
            }
        });
    }
}

Trait Implementations

impl AsyncRead for UdpStreamReadHalf

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<(), Error>>

Attempts to read from the AsyncRead into buf.