ar_pe_ce
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,