pub fn stream_messages_with_timeout<R: AsyncRead + Unpin>( input: R, timeout_duration: Duration ) -> impl Stream<Item = Result<Sbp, Error>>