Function ar_pe_ce_core::decode_stream

pub fn decode_stream<T>(
    stream: impl Stream<Item = Result<Bytes, Error>> + Send + 'static
) -> impl Stream<Item = Result<T>> + Send where
    T: DeserializeOwned + Send,