pub type MessagesStream = UnboundedReceiver<StreamMessage>;
pub struct MessagesStream { /* private fields */ }