Type Alias MessageStream 

pub type MessageStream = Box<dyn Stream<Item = Result<Bytes, MessageBrokerError>> + Send + Unpin>;

Aliased Type

pub struct MessageStream(/* private fields */);