Trait dbcrossbarlib::tokio_glue::ConsumeWithParallelism

pub trait ConsumeWithParallelism<T>: Sized {
    fn consume_with_parallelism(self, parallelism: usize) -> BoxFuture<Vec<T>>;
}

Extension for BoxStream<BoxFuture<()>>.

Required methods

fn consume_with_parallelism(self, parallelism: usize) -> BoxFuture<Vec<T>>

Consume futures from the stream, running parallelism futures at any given time.

Implementors

impl<T: Send + Sized + 'static> ConsumeWithParallelism<T> for BoxStream<BoxFuture<T>>