Trait mhost::utils::buffer_unordered_with_breaker::StreamExtBufferUnorderedWithBreaker[−][src]

pub trait StreamExtBufferUnorderedWithBreaker: StreamExt {
    fn buffered_unordered_with_breaker(
        self, 
        n: usize, 
        breaker: Box<dyn Fn(&<Self::Item as Future>::Output) -> bool + Send>
    ) -> BufferUnorderedWithBreaker<Self>
    where
        Self: Sized,
        Self::Item: Future,
    { ... }
}

Provided methods

fn buffered_unordered_with_breaker(
    self,
    n: usize,
    breaker: Box<dyn Fn(&<Self::Item as Future>::Output) -> bool + Send>
) -> BufferUnorderedWithBreaker<Self> where
    Self: Sized,
    Self::Item: Future, [src]

Loading content...

Implementors

impl<T: ?Sized> StreamExtBufferUnorderedWithBreaker for T where
    T: StreamExt, [src]

Loading content...