Trait tokio_batch::ChunksTimeoutStreamExt

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

Provided methods

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

Loading content...

Implementors

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

Loading content...