Function sbp::json::stream_messages

source · 
pub fn stream_messages<R: AsyncRead + Unpin>(
    input: R
) -> impl Stream<Item = Result<Sbp, JsonError>>
Expand description

Deserialize the async IO stream into an stream of messages.