pub fn get_messages( bytes: impl AsyncBufRead + Send + 'static + Unpin, ) -> ReceiverStream<Result<Message>>