Trait snocat::util::tunnel_stream::TunnelStream

pub trait TunnelStream: AsyncRead + AsyncWrite + Send + Unpin {
    fn as_boxed_ref<'a>(&'a mut self) -> Box<&'a mut dyn TunnelStream>
    where
        Self: Sized,
    { ... }
}

A duplex stream abstracting over a connection, allowing use of memory streams and Quinn connections

Provided methods

fn as_boxed_ref<'a>(&'a mut self) -> Box<&'a mut dyn TunnelStream> where
    Self: Sized, 

Trait Implementations

impl AsyncRead for dyn TunnelStream

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

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 AsyncWrite for dyn TunnelStream

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

Attempt to write bytes from buf into the object.

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

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<(), IOError>>

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.

Implementors

impl TunnelStream for WrappedStream

impl<T: Deref<Target = dyn TunnelStream + Send> + AsyncWrite + AsyncRead + Send + Unpin> TunnelStream for T

impl<TSession: Session> TunnelStream for QuinnTunnelRefStream<'_, TSession>

impl<TSession: Session> TunnelStream for QuinnTunnelStream<TSession>