pub fn encode<T, S>( source: S, compression_encoding: Option<CompressionEncoding>, ) -> BoxStream<'static, Result<Frame<Bytes>, Status>>where S: Stream<Item = Result<T, Status>> + Send + 'static, T: Message + 'static,