Function dubbo::triple::encode::encode_client
source · pub fn encode_client<E, B>(
encoder: E,
body: B,
compression_encoding: Option<CompressionEncoding>
) -> EncodeBody<impl Stream<Item = Result<Bytes, Status>>>where
E: Encoder<Error = Status>,
B: Stream<Item = E::Item>,