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.

Implementors

impl<St> RwTryStreamExt for St

where St: TryStream,