Struct MemoryDatagramSocket 

pub struct MemoryDatagramSocket { /* private fields */ }

Available on crate feature std and crate feature udp and (crate features test-utils) only.

One endpoint of an in-memory datagram pair used by protocol tests.

Sending from either endpoint queues a datagram for the other. The fixed queue capacity models backpressure without using an operating-system socket.

Implementations

impl MemoryDatagramSocket

pub fn pair( first: impl Into<SocketAddress>, second: impl Into<SocketAddress>, capacity: NonZero<usize>, ) -> (MemoryDatagramSocket, MemoryDatagramSocket)

Construct two connected endpoints with capacity datagrams per side.

pub fn inject_received( &self, payload: Vec<u8>, metadata: DatagramMetadata, ) -> Result<(), DatagramError>

Insert a datagram directly into this endpoint’s receive queue.

This is useful for deterministic tests of metadata that cannot be produced by the ordinary paired send path, such as original destination.

pub fn set_max_send_segments(&self, value: NonZero<usize>)

Change the segmented-send limit exposed by both endpoints.

This deterministic hook lets protocol tests model a backend that lowers its offload limit after a runtime rejection. Already-created sender handles observe the new value through their next capability query.

Trait Implementations

impl DatagramSocket for MemoryDatagramSocket

type Sender = MemoryDatagramSender

Independently wakeable send handle created by this socket.

fn create_sender(&self) -> <MemoryDatagramSocket as DatagramSocket>::Sender

Create a send handle with independent readiness registration.

fn poll_recv( &mut self, cx: &mut Context<'_>, buffers: &mut [IoSliceMut<'_>], metadata: &mut [DatagramMetadata], ) -> Poll<Result<usize, DatagramError>>

Receive one or more datagrams, or register for readiness.

fn capabilities(&self) -> DatagramCapabilities

Current runtime-detected capabilities.

impl Debug for MemoryDatagramSocket

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

Formats the value using the given formatter.

impl Drop for MemoryDatagramSocket

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Socket for MemoryDatagramSocket

fn local_addr(&self) -> Result<SocketAddress, Error>

Try to get the local address of the socket.

fn peer_addr(&self) -> Result<SocketAddress, Error>

Try to get the remote address of the socket.