Type Definition dbcrossbarlib::tokio_glue::BoxStream

pub type BoxStream<T, E = Error> = BoxStream<'static, Result<T, E>>;

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.