Trait RwTryStreamExt 

pub trait RwTryStreamExt: TryStream {
    // Required method
    fn try_buffered_with_fence(self, n: usize) -> TryBufferedWithFence<Self>
       where Self: Sized,
             Self::Ok: TryFuture<Error = Self::Error> + MaybeFence;
}

Required Methods

fn try_buffered_with_fence(self, n: usize) -> TryBufferedWithFence<Self>

where Self: Sized, Self::Ok: TryFuture<Error = Self::Error> + MaybeFence,

Similar to TryStreamExt::try_buffered, but respect to fence.

Fence is provided by Future that implements MaybeFence and returns true. When the stream receive a fenced future, it’ll not do a sync operation. In brief, don’t poll later futures until the current buffer is cleared.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<St> RwTryStreamExt for St

where St: TryStream,