[−][src]Trait dbcrossbarlib::tokio_glue::ConsumeWithParallelism
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.