Struct ssb_boxstream::BoxStream

pub struct BoxStream<R, W> { /* fields omitted */ }

Implementations

impl<R, W> BoxStream<R, W> where
    R: AsyncRead + Unpin + 'static,
    W: AsyncWrite + Unpin + 'static, 

pub fn new(
    r: R,
    w: W,
    r_key: Key,
    r_nonce: Nonce,
    w_key: Key,
    w_nonce: Nonce
) -> BoxStream<R, W>

pub fn split(self) -> (BoxReader<R, Vec<u8>>, BoxWriter<W, Vec<u8>>)

Trait Implementations

impl<R, W> AsyncRead for BoxStream<R, W> where
    R: Unpin + AsyncRead + 'static,
    W: Unpin + AsyncWrite + 'static, 

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

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<R, W> AsyncWrite for BoxStream<R, W> where
    R: Unpin + AsyncRead + 'static,
    W: Unpin + AsyncWrite + 'static, 

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

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

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.