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)

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, Error>>

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, Error>>

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

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: 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.