pub type MessageStream = Pin<Box<dyn Stream<Item = Result<StreamEvent>> + Send + 'static>>;
Boxed dynamic stream of stream events.
pub struct MessageStream { /* private fields */ }