Function sbp::stream_messages_with_timeout

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