Function sbp::iter_messages_with_timeout
source · [−]pub fn iter_messages_with_timeout<R: Read>(
input: R,
timeout_duration: Duration
) -> impl Iterator<Item = Result<Sbp, Error>>
Expand description
Deserialize the IO stream into an iterator of messages. Provide a timeout for the maximum allowed duration without a successful message.