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 fault_control(&self) -> MemoryDatagramControl

Control loss and reordering on datagrams sent by this endpoint.

The handle does not keep either endpoint logically open.

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.

pub fn set_max_payload(&self, value: usize)

Lower the payload limit both endpoints expose and enforce, as a UDP tunnel whose path shrank does; larger sends fail with DatagramError::PayloadTooLarge. Existing sender handles observe it on their next send.

pub fn set_send_source_port(&self, enabled: bool)

Let both endpoints select a reply’s source port too (off by default), as a transparent proxy flow can.

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 ExtensionsRef for MemoryDatagramSocket

fn extensions(&self) -> &Extensions

Get reference to the underlying Extensions store

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.