Struct Socket

pub struct Socket<T> { /* private fields */ }

Implementations

impl<T: AnySocket<'static>> Socket<T>

pub fn with<R>(&self, f: impl FnOnce(&T) -> R) -> R

pub fn with_mut<R>(&mut self, f: impl FnOnce(&mut T) -> R) -> R

pub fn with_context_mut<R>( &mut self, f: impl FnOnce(&mut Context, &mut T) -> R, ) -> R

impl Socket<Socket<'static>>

pub async fn connect<T, U>( &mut self, remote_endpoint: T, local_endpoint: U, ) -> Result<(), TcpSocketError>

where T: Into<IpEndpoint>, U: Into<IpListenEndpoint>,

pub async fn accept_with_keep_alive( &mut self, local_endpoint: impl Into<IpListenEndpoint>, keep_alive_interval: Option<Duration>, ) -> Result<(), TcpSocketError>

pub async fn accept( &mut self, local_endpoint: impl Into<IpListenEndpoint>, ) -> Result<(), TcpSocketError>

pub fn close(&mut self)

pub fn abort(&mut self)

Trait Implementations

impl<T> Drop for Socket<T>

fn drop(&mut self)

Executes the destructor for this type.

impl ErrorType for Socket<Socket<'static>>

type Error = TcpSocketError

Error type of all the IO operations on this type.

impl Read for Socket<Socket<'static>>

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

impl Write for Socket<Socket<'static>>

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

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>