Type Definition dbcrossbarlib::tokio_glue::BoxFuture

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

Standard future type for this library. Like Result, but used by async. We mark it as Send to ensure it can be sent between threads safely (even when blocked on .await!), and we Pin<Box<...>> it using .boxed() to make it an abstract, heap-based type, for convenience. All we know is that it will return a Result<T>.

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.