Type Alias DataStream

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

Aliased Type

struct DataStream<T> {}

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.