Trait futures_batch::ChunksTimeoutStreamExt

pub trait ChunksTimeoutStreamExt: Stream {
    fn chunks_timeout(
        self,
        capacity: usize,
        duration: Duration
    ) -> ChunksTimeout<Self>
    where
        Self: Sized,
    { ... }
}

A Stream extension trait allowing you to call chunks_timeout on anything which implements Stream.

Provided Methods

fn chunks_timeout(
    self,
    capacity: usize,
    duration: Duration
) -> ChunksTimeout<Self>where
    Self: Sized,

Implementors

impl<T: ?Sized> ChunksTimeoutStreamExt for Twhere
    T: Stream,