Struct IpStackUdpStream 

pub struct IpStackUdpStream { /* private fields */ }

A UDP stream in the IP stack.

This type represents a UDP connection and implements AsyncRead and AsyncWrite for bidirectional data transfer. UDP streams have a configurable timeout and automatically handle packet fragmentation based on MTU.

Examples

use ipstack::{IpStack, IpStackConfig, IpStackStream};
use tokio::io::{AsyncReadExt, AsyncWriteExt};

if let IpStackStream::Udp(mut udp_stream) = ip_stack.accept().await? {
    println!("New UDP stream from {}", udp_stream.peer_addr());
     
    // Read data
    let mut buffer = [0u8; 1024];
    let n = udp_stream.read(&mut buffer).await?;
     
    // Write data
    udp_stream.write_all(b"Response").await?;
}

Implementations

impl IpStackUdpStream

pub fn new( src_addr: SocketAddr, dst_addr: SocketAddr, payload: Vec<u8>, up_pkt_sender: UnboundedSender<NetworkPacket>, mtu: u16, timeout_interval: Duration, destroy_messenger: Option<Sender<()>>, ) -> Self

pub fn local_addr(&self) -> SocketAddr

Returns the local socket address of the UDP stream.

Examples

let local_addr = udp_stream.local_addr();
println!("Local address: {}", local_addr);

pub fn peer_addr(&self) -> SocketAddr

Returns the remote socket address of the UDP stream.

Examples

let peer_addr = udp_stream.peer_addr();
println!("Peer address: {}", peer_addr);

Trait Implementations

impl AsyncRead for IpStackUdpStream

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

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for IpStackUdpStream

fn poll_write( self: Pin<&mut Self>, _cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl Debug for IpStackUdpStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for IpStackUdpStream

fn drop(&mut self)

Executes the destructor for this type.