pub type LogStream = EventStream<EventBlock<LogMsgQueue>>;
pub struct LogStream { /* private fields */ }