Trait netlink_proto::sys::AsyncSocket

pub trait AsyncSocket: Sized + Unpin {
    // Required methods
    fn socket_ref(&self) -> &Socket;
    fn socket_mut(&mut self) -> &mut Socket;
    fn new(protocol: isize) -> Result<Self, Error>;
    fn poll_send(
        &mut self,
        cx: &mut Context<'_>,
        buf: &[u8]
    ) -> Poll<Result<usize, Error>>;
    fn poll_send_to(
        &mut self,
        cx: &mut Context<'_>,
        buf: &[u8],
        addr: &SocketAddr
    ) -> Poll<Result<usize, Error>>;
    fn poll_recv<B>(
        &mut self,
        cx: &mut Context<'_>,
        buf: &mut B
    ) -> Poll<Result<(), Error>>
       where B: BufMut;
    fn poll_recv_from<B>(
        &mut self,
        cx: &mut Context<'_>,
        buf: &mut B
    ) -> Poll<Result<SocketAddr, Error>>
       where B: BufMut;
    fn poll_recv_from_full(
        &mut self,
        cx: &mut Context<'_>
    ) -> Poll<Result<(Vec<u8>, SocketAddr), Error>>;
}

Trait to support different async backends

Required Methods

fn socket_ref(&self) -> &Socket

Access underyling Socket

fn socket_mut(&mut self) -> &mut Socket

Mutable access to underyling Socket

fn new(protocol: isize) -> Result<Self, Error>

Wrapper for Socket::new

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

Polling wrapper for Socket::send

fn poll_send_to( &mut self, cx: &mut Context<'_>, buf: &[u8], addr: &SocketAddr ) -> Poll<Result<usize, Error>>

Polling wrapper for Socket::send_to

fn poll_recv<B>( &mut self, cx: &mut Context<'_>, buf: &mut B ) -> Poll<Result<(), Error>>

where B: BufMut,

Polling wrapper for Socket::recv

Passes 0 for flags, and ignores the returned length (the buffer will have advanced by the amount read).

fn poll_recv_from<B>( &mut self, cx: &mut Context<'_>, buf: &mut B ) -> Poll<Result<SocketAddr, Error>>

where B: BufMut,

Polling wrapper for Socket::recv_from

Passes 0 for flags, and ignores the returned length - just returns the address (the buffer will have advanced by the amount read).

fn poll_recv_from_full( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(Vec<u8>, SocketAddr), Error>>

Polling wrapper for Socket::recv_from_full

Passes 0 for flags, and ignores the returned length - just returns the address (the buffer will have advanced by the amount read).

Object Safety

This trait is not object safe.

Implementors

impl AsyncSocket for TokioSocket