Trait AsyncRecvStreamHandle 

pub trait AsyncRecvStreamHandle: AsyncStreamHandle {
    // Required methods
    fn read<'a>(
        &'a self,
        dst: &'a mut [u8],
    ) -> AsyncBoxFuture<'a, Result<usize>>;
    fn read_timeout<'a>(
        &'a self,
        dst: &'a mut [u8],
        timeout: Duration,
    ) -> AsyncBoxFuture<'a, Result<usize>>;
    fn is_read_closed(&self) -> bool;
    fn close_read(&self) -> AsyncBoxFuture<'_, Result<()>>;
    fn cancel_read(&self, code: u64) -> AsyncBoxFuture<'_, Result<()>>;

    // Provided methods
    fn read_vectored<'a>(
        &'a self,
        dsts: &'a mut [IoSliceMut<'_>],
    ) -> AsyncBoxFuture<'a, Result<usize>> { ... }
    fn read_vectored_timeout<'a>(
        &'a self,
        dsts: &'a mut [IoSliceMut<'_>],
        timeout: Duration,
    ) -> AsyncBoxFuture<'a, Result<usize>> { ... }
    fn read_exact<'a>(
        &'a self,
        dst: &'a mut [u8],
    ) -> AsyncBoxFuture<'a, Result<()>> { ... }
    fn read_exact_timeout<'a>(
        &'a self,
        dst: &'a mut [u8],
        timeout: Duration,
    ) -> AsyncBoxFuture<'a, Result<()>> { ... }
    fn set_read_deadline(&self, deadline: Option<Instant>) -> Result<()> { ... }
    fn set_read_timeout(&self, timeout: Option<Duration>) -> Result<()> { ... }
    fn read_to_end<'a>(
        &'a self,
        dst: &'a mut Vec<u8>,
    ) -> AsyncBoxFuture<'a, Result<usize>> { ... }
    fn read_to_end_limited(
        &self,
        max_bytes: usize,
    ) -> AsyncBoxFuture<'_, Result<Vec<u8>>> { ... }
}

Runtime-neutral receive stream operations.

Required Methods

fn read<'a>(&'a self, dst: &'a mut [u8]) -> AsyncBoxFuture<'a, Result<usize>>

fn read_timeout<'a>( &'a self, dst: &'a mut [u8], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<usize>>

fn is_read_closed(&self) -> bool

fn close_read(&self) -> AsyncBoxFuture<'_, Result<()>>

fn cancel_read(&self, code: u64) -> AsyncBoxFuture<'_, Result<()>>

Provided Methods

fn read_vectored<'a>( &'a self, dsts: &'a mut [IoSliceMut<'_>], ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_vectored_timeout<'a>( &'a self, dsts: &'a mut [IoSliceMut<'_>], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_exact<'a>(&'a self, dst: &'a mut [u8]) -> AsyncBoxFuture<'a, Result<()>>

fn read_exact_timeout<'a>( &'a self, dst: &'a mut [u8], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<()>>

fn set_read_deadline(&self, deadline: Option<Instant>) -> Result<()>

fn set_read_timeout(&self, timeout: Option<Duration>) -> Result<()>

fn read_to_end<'a>( &'a self, dst: &'a mut Vec<u8>, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_to_end_limited( &self, max_bytes: usize, ) -> AsyncBoxFuture<'_, Result<Vec<u8>>>

Implementations on Foreign Types

impl<T> AsyncRecvStreamHandle for &T

where T: AsyncRecvStreamHandle + ?Sized,

fn read<'a>(&'a self, dst: &'a mut [u8]) -> AsyncBoxFuture<'a, Result<usize>>

fn read_vectored<'a>( &'a self, dsts: &'a mut [IoSliceMut<'_>], ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_timeout<'a>( &'a self, dst: &'a mut [u8], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_vectored_timeout<'a>( &'a self, dsts: &'a mut [IoSliceMut<'_>], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_exact<'a>(&'a self, dst: &'a mut [u8]) -> AsyncBoxFuture<'a, Result<()>>

fn read_exact_timeout<'a>( &'a self, dst: &'a mut [u8], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<()>>

fn is_read_closed(&self) -> bool

fn set_read_deadline(&self, deadline: Option<Instant>) -> Result<()>

fn read_to_end<'a>( &'a self, dst: &'a mut Vec<u8>, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_to_end_limited( &self, max_bytes: usize, ) -> AsyncBoxFuture<'_, Result<Vec<u8>>>

fn close_read(&self) -> AsyncBoxFuture<'_, Result<()>>

fn cancel_read(&self, code: u64) -> AsyncBoxFuture<'_, Result<()>>

impl<T> AsyncRecvStreamHandle for &mut T

where T: AsyncRecvStreamHandle + ?Sized,

fn read<'a>(&'a self, dst: &'a mut [u8]) -> AsyncBoxFuture<'a, Result<usize>>

fn read_vectored<'a>( &'a self, dsts: &'a mut [IoSliceMut<'_>], ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_timeout<'a>( &'a self, dst: &'a mut [u8], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_vectored_timeout<'a>( &'a self, dsts: &'a mut [IoSliceMut<'_>], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_exact<'a>(&'a self, dst: &'a mut [u8]) -> AsyncBoxFuture<'a, Result<()>>

fn read_exact_timeout<'a>( &'a self, dst: &'a mut [u8], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<()>>

fn is_read_closed(&self) -> bool

fn set_read_deadline(&self, deadline: Option<Instant>) -> Result<()>

fn read_to_end<'a>( &'a self, dst: &'a mut Vec<u8>, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_to_end_limited( &self, max_bytes: usize, ) -> AsyncBoxFuture<'_, Result<Vec<u8>>>

fn close_read(&self) -> AsyncBoxFuture<'_, Result<()>>

fn cancel_read(&self, code: u64) -> AsyncBoxFuture<'_, Result<()>>

impl<T> AsyncRecvStreamHandle for Box<T>

where T: AsyncRecvStreamHandle + ?Sized,

fn read<'a>(&'a self, dst: &'a mut [u8]) -> AsyncBoxFuture<'a, Result<usize>>

fn read_vectored<'a>( &'a self, dsts: &'a mut [IoSliceMut<'_>], ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_timeout<'a>( &'a self, dst: &'a mut [u8], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_vectored_timeout<'a>( &'a self, dsts: &'a mut [IoSliceMut<'_>], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_exact<'a>(&'a self, dst: &'a mut [u8]) -> AsyncBoxFuture<'a, Result<()>>

fn read_exact_timeout<'a>( &'a self, dst: &'a mut [u8], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<()>>

fn is_read_closed(&self) -> bool

fn set_read_deadline(&self, deadline: Option<Instant>) -> Result<()>

fn read_to_end<'a>( &'a self, dst: &'a mut Vec<u8>, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_to_end_limited( &self, max_bytes: usize, ) -> AsyncBoxFuture<'_, Result<Vec<u8>>>

fn close_read(&self) -> AsyncBoxFuture<'_, Result<()>>

fn cancel_read(&self, code: u64) -> AsyncBoxFuture<'_, Result<()>>

impl<T> AsyncRecvStreamHandle for Arc<T>

where T: AsyncRecvStreamHandle + ?Sized,

fn read<'a>(&'a self, dst: &'a mut [u8]) -> AsyncBoxFuture<'a, Result<usize>>

fn read_vectored<'a>( &'a self, dsts: &'a mut [IoSliceMut<'_>], ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_timeout<'a>( &'a self, dst: &'a mut [u8], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_vectored_timeout<'a>( &'a self, dsts: &'a mut [IoSliceMut<'_>], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_exact<'a>(&'a self, dst: &'a mut [u8]) -> AsyncBoxFuture<'a, Result<()>>

fn read_exact_timeout<'a>( &'a self, dst: &'a mut [u8], timeout: Duration, ) -> AsyncBoxFuture<'a, Result<()>>

fn is_read_closed(&self) -> bool

fn set_read_deadline(&self, deadline: Option<Instant>) -> Result<()>

fn read_to_end<'a>( &'a self, dst: &'a mut Vec<u8>, ) -> AsyncBoxFuture<'a, Result<usize>>

fn read_to_end_limited( &self, max_bytes: usize, ) -> AsyncBoxFuture<'_, Result<Vec<u8>>>

fn close_read(&self) -> AsyncBoxFuture<'_, Result<()>>

fn cancel_read(&self, code: u64) -> AsyncBoxFuture<'_, Result<()>>

Implementors

impl AsyncRecvStreamHandle for RecvStream

impl AsyncRecvStreamHandle for Stream

impl<R, W> AsyncRecvStreamHandle for AsyncDuplexStream<R, W>

where R: AsyncRecvStreamHandle, W: AsyncSendStreamHandle,