Type Alias DataStream 

pub type DataStream<T> = Pin<Box<dyn Stream<Item = T> + Send>>;

Aliased Type

pub struct DataStream<T> { /* private fields */ }

Trait Implementations

impl<T: Data> From<Pin<Box<dyn AsyncEngineStream<T, Item = T>>>> for DataStream<T>

fn from(stream: EngineStream<T>) -> Self

Converts to this type from the input type.