pub fn stream_messages<R: AsyncRead + Unpin>( input: R ) -> impl Stream<Item = Result<Sbp, Error>>
Deserialize the async IO stream into an stream of messages.