Enum trillium_server_common::Binding

pub enum Binding<T, U> {
    Tcp(T),
    Unix(U),
}

A wrapper enum that has blanket implementations for common traits like TryFrom, Stream, AsyncRead, and AsyncWrite. This can contain listeners (like TcpListener), Streams (like Incoming), or bytestreams (like TcpStream).

Variants

Tcp(T)

a tcp type (listener or incoming or stream)

Unix(U)

a unix type (listener or incoming or stream)

Implementations

impl<T, U> Binding<T, U>

pub fn get_tcp(&self) -> Option<&T>

borrows the tcp stream or listener, if this is a tcp variant

pub fn get_unix(&self) -> Option<&U>

borrows the unix stream or listener, if this is unix variant

pub fn get_tcp_mut(&mut self) -> Option<&mut T>

mutably borrows the tcp stream or listener, if this is tcp variant

pub fn get_unix_mut(&mut self) -> Option<&mut U>

mutably borrows the unix stream or listener, if this is unix variant

Trait Implementations

impl<T, U> AsyncRead for Binding<T, U>

where T: AsyncRead + Unpin, U: AsyncRead + Unpin,

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

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl<T, U> AsyncWrite for Binding<T, U>

where T: AsyncWrite + Unpin, U: AsyncWrite + Unpin,

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

Attempt to write bytes from buf into the object.

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

Attempt to flush the object, ensuring that any buffered data reach their destination.

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

Attempt to close the object.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize>>

Attempt to write bytes from bufs into the object using vectored IO operations.

impl<T: Clone, U: Clone> Clone for Binding<T, U>

fn clone(&self) -> Binding<T, U>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug, U: Debug> Debug for Binding<T, U>

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

Formats the value using the given formatter.

impl<T, U, TI, UI> Stream for Binding<T, U>

where T: Stream<Item = Result<TI>> + Unpin, U: Stream<Item = Result<UI>> + Unpin,

type Item = Result<Binding<TI, UI>, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<T, U> Transport for Binding<T, U>

where T: Transport, U: Transport,

fn set_linger(&mut self, linger: Option<Duration>) -> Result<()>

Sets the linger duration of this transport by setting the SO_LINGER option

fn set_nodelay(&mut self, nodelay: bool) -> Result<()>

Sets the value of the TCP_NODELAY option on this transport.

fn set_ip_ttl(&mut self, ttl: u32) -> Result<()>

Sets the value for the IP_TTL option on this transport.

fn peer_addr(&self) -> Result<Option<SocketAddr>>

Returns the socket address of the remote peer of this transport.

impl<T: TryFrom<TcpListener>, U> TryFrom<TcpListener> for Binding<T, U>

type Error = <T as TryFrom<TcpListener>>::Error

The type returned in the event of a conversion error.

fn try_from(value: TcpListener) -> Result<Self, Self::Error>

Performs the conversion.

impl<T, U: TryFrom<UnixListener>> TryFrom<UnixListener> for Binding<T, U>

type Error = <U as TryFrom<UnixListener>>::Error

The type returned in the event of a conversion error.

fn try_from(value: UnixListener) -> Result<Self, Self::Error>

Performs the conversion.