Struct PrefixedDatagramSocket 

pub struct PrefixedDatagramSocket<S> { /* private fields */ }

Available on crate features std and udp only.

A DatagramSocket that first yields the datagrams an inspection read ahead, in order and with their boundaries and metadata, and only then what inner receives.

Sending goes straight to inner.

Implementations

impl<S> PrefixedDatagramSocket<S>

pub fn new( inner: S, prefix: impl IntoIterator<Item = RetainedDatagram>, ) -> PrefixedDatagramSocket<S>

Replay prefix before anything inner receives later.

pub fn retained(&self) -> &VecDeque<RetainedDatagram>

The datagrams not yet received from this socket.

pub fn get_ref(&self) -> &S

The underlying socket.

Trait Implementations

impl<S> DatagramSocket for PrefixedDatagramSocket<S>

where S: DatagramSocket,

type Sender = <S as DatagramSocket>::Sender

Independently wakeable send handle created by this socket.

fn create_sender(&self) -> <PrefixedDatagramSocket<S> 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<S> Debug for PrefixedDatagramSocket<S>

where S: Debug,

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

Formats the value using the given formatter.

impl<S> ExtensionsRef for PrefixedDatagramSocket<S>

where S: ExtensionsRef,

fn extensions(&self) -> &Extensions

Get reference to the underlying Extensions store

impl<S> Socket for PrefixedDatagramSocket<S>

where S: Socket,

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.