Function dubbo::triple::encode::encode

source ·
pub fn encode<E, B>(
    encoder: E,
    resp_body: B,
    compression_encoding: Option<CompressionEncoding>
) -> impl TryStream<Ok = Bytes, Error = Status>where
    E: Encoder<Error = Status>,
    B: Stream<Item = Result<E::Item, Status>>,