Function ar_pe_ce::encode_stream

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