Struct Socket 

pub struct Socket<A, S> { /* private fields */ }

Implementations

impl<A: NetworkAddress, S> Socket<A, S>

pub fn local_addr(&self) -> A

pub fn poll_recv( &self, buf: &mut [u8], cx: &mut Context<'_>, ) -> Poll<Result<RecvResult<A>>>

Poll to receive a packet on the socket.

Note that on multiple calls to poll_recv, only the Waker from the Context on the most recent call is scheduled to receive a wakeup.

pub async fn recv(&self, buf: &mut [u8]) -> Result<RecvResult<A>>

pub fn get_send_timestamp( &self, ) -> impl Future<Output = Result<(SendTimestampToken, TimestampData)>> + Send + Sync + 'static

Wait for the next send timestamp to be returned.

Note: There is no poll variant for this function, as that is currently impossible to implement with the tools tokio provides. To compensate, the future returned here is independent of the self reference and can be stored to simulate the existence of a poll function.

impl<A: NetworkAddress> Socket<A, Open>

pub fn poll_send_to( &self, buf: &[u8], addr: A, cx: &mut Context<'_>, ) -> Poll<Result<Option<SendTimestampToken>>>

Send a packet to a given receiver on the socket.

Note that on multiple calls to poll_send_*, only the Waker from the Context on the most recent call is scheduled to receive a wakeup.

pub async fn send_to(&mut self, buf: &[u8], addr: A) -> Result<TimestampData>

Send a packet to a given receiver on the socket.

When used in combination with the polling send functions, if there are timestamps pending for some SendTimestampToken, these may be skipped and become unavailable when calling this function.

pub fn poll_send_from_to( &self, buf: &[u8], from: A, to: A, cx: &mut Context<'_>, ) -> Poll<Result<Option<SendTimestampToken>>>

Send a packet to a given receiver on the socket, using the specified origin address.

Note that on multiple calls to poll_send_*, only the Waker from the Context on the most recent call is scheduled to receive a wakeup.

pub async fn send_from_to( &mut self, buf: &[u8], from: A, to: A, ) -> Result<TimestampData>

Send a packet to a given receiver on the socket, using the specified origin address.

When used in combination with the polling send functions, if there are timestamps pending for some SendTimestampToken, these may be skipped and become unavailable when calling this function.

pub fn connect(self, addr: A) -> Result<Socket<A, Connected>>

impl<A: NetworkAddress> Socket<A, Connected>

pub fn peer_addr(&self) -> Result<A>

pub fn poll_send( &self, buf: &[u8], cx: &mut Context<'_>, ) -> Poll<Result<Option<SendTimestampToken>>>

Send a packet on the socket.

Note that on multiple calls to poll_send_*, only the Waker from the Context on the most recent call is scheduled to receive a wakeup.

pub async fn send(&mut self, buf: &[u8]) -> Result<TimestampData>

Send a packet on the socket.

When used in combination with the polling send functions, if there are timestamps pending for some SendTimestampToken, these may be skipped and become unavailable when calling this function.

pub fn poll_send_from( &self, buf: &[u8], from: A, cx: &mut Context<'_>, ) -> Poll<Result<Option<SendTimestampToken>>>

Send a packet on the socket.

Note that on multiple calls to poll_send_*, only the Waker from the Context on the most recent call is scheduled to receive a wakeup.

pub async fn send_from(&mut self, buf: &[u8], from: A) -> Result<TimestampData>

Send a packet on the socket, with the given local address.

When used in combination with the polling send functions, if there are timestamps pending for some SendTimestampToken, these may be skipped and become unavailable when calling this function.

impl<A: MulticastJoinable, S> Socket<A, S>

pub fn join_multicast(&self, addr: A, interface: InterfaceName) -> Result<()>

pub fn leave_multicast(&self, addr: A, interface: InterfaceName) -> Result<()>

Trait Implementations

impl<A: Debug, S: Debug> Debug for Socket<A, S>

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

Formats the value using the given formatter.