Type Definition dbcrossbarlib::tokio_glue::BoxStream

type BoxStream<T> = Box<dyn Stream<Item = T, Error = Error> + Send + 'static>;

A stream of values of type T, using our standard error type, and imposing enough restrictions to be able send streams between threads.

Trait Implementations

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

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

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