Function ar_pe_ce_core::encode_stream

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