Struct ore::netio::SniffedStream

pub struct SniffedStream<A> {
    inner: A,
    buf: SmallVec<[u8; 8]>,
    off: usize,
}

This is supported on crate feature network only.

A SniffingStream that has relinquished its capability to sniff bytes.

Fields

inner: A

buf: SmallVec<[u8; 8]>

off: usize

Implementations

impl<A> SniffedStream<A> where
    A: Unpin, 

pub fn get_ref(&self) -> &A

Returns a reference to the underlying stream.

pub fn sniff_buffer(&self) -> &[u8]

Returns a reference to the bytes that were sniffed at the beginning of the stream.

pub fn into_inner(self) -> A

Consumes the SniffedStream, returning the underlying stream. Be very careful with this function! The underlying stream pointer will have been advanced past any bytes sniffed from the SniffingStream that created this SniffedStream.

fn inner_pin(&mut self) -> Pin<&mut A>

Trait Implementations

impl<A> AsyncRead for SniffedStream<A> where
    A: AsyncRead + Unpin, 

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

Attempts to read from the AsyncRead into buf.

impl<A> AsyncReady for SniffedStream<A> where
    A: AsyncReady + Send + Sync, 

fn ready<'life0, 'async_trait>(
    &'life0 self,
    interest: Interest
) -> Pin<Box<dyn Future<Output = Result<Ready>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Checks for IO readiness.

impl<A> AsyncWrite for SniffedStream<A> where
    A: AsyncWrite + Unpin, 

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

Attempt to write bytes from buf into the object.

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

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

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

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

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

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl<A> Debug for SniffedStream<A>

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

Formats the value using the given formatter.