Trait mhost::utils::buffer_unordered_with_breaker::StreamExtBufferUnorderedWithBreaker

pub trait StreamExtBufferUnorderedWithBreaker: StreamExt {
    // Provided method
    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,

Object Safety

This trait is not object safe.

Implementors

impl<T> StreamExtBufferUnorderedWithBreaker for T

where T: StreamExt + ?Sized,