Trait dbcrossbarlib::tokio_glue::ConsumeWithParallelism [−][src]
Extension for BoxStream<BoxFuture<()>>
.
Required methods
fn consume_with_parallelism(self, parallelism: usize) -> BoxFuture<Vec<T>>
[src]
Consume futures from the stream, running parallelism
futures at any
given time.