Home
last modified time | relevance | path

Searched refs:Decoder (Results 1 – 9 of 9) sorted by relevance

/tonic/examples/src/codec_buffers/
H A Dcommon.rs29 type Decoder = <ProstCodec<T, U> as Codec>::Decoder; typedef
38 fn decoder(&mut self) -> Self::Decoder { in decoder() argument
/tonic/tonic/src/codec/
H A Dmod.rs113 type Decoder: Decoder<Item = Self::Decode, Error = Status> + Send + 'static; typedef
118 fn decoder(&mut self) -> Self::Decoder; in decoder() argument
141 pub trait Decoder { trait
H A Dprost.rs1 use super::{BufferSettings, Codec, DecodeBuf, Decoder, Encoder};
43 pub fn raw_decoder(buffer_settings: BufferSettings) -> <Self as Codec>::Decoder { in raw_decoder() argument
60 type Decoder = ProstDecoder<U>; typedef
69 fn decoder(&mut self) -> Self::Decoder { in decoder() argument
127 impl<U: Message + Default> Decoder for ProstDecoder<U> {
154 DecodeBuf, Decoder, EncodeBody, EncodeBuf, Encoder, Streaming, HEADER_SIZE,
334 impl Decoder for MockDecoder {
H A Ddecode.rs2 use super::{BufferSettings, DecodeBuf, Decoder, DEFAULT_MAX_RECV_MESSAGE_SIZE, HEADER_SIZE};
22 decoder: Box<dyn Decoder<Item = T, Error = Status> + Send + 'static>,
69 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_response()
85 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_empty()
101 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_request()
122 D: Decoder<Item = T, Error = Status> + Send + 'static, in new()
H A Dcompression.rs9 use zstd::stream::read::{Decoder, Encoder};
290 let mut zstd_decoder = Decoder::new(&compressed_buf[0..len])?; in decompress()
/tonic/examples/src/json-codec/
H A Dcommon.rs9 codec::{Codec, DecodeBuf, Decoder, EncodeBuf, Encoder},
38 impl<U: serde::de::DeserializeOwned> Decoder for JsonDecoder<U> {
71 type Decoder = JsonDecoder<U>; typedef
77 fn decoder(&mut self) -> Self::Decoder { in decoder() argument
/tonic/tonic/benches/
H A Ddecode.rs11 use tonic::{codec::DecodeBuf, codec::Decoder, Status, Streaming};
102 impl Decoder for MockDecoder {
/tonic/tonic/src/client/
H A Dgrpc.rs7 codec::{Codec, Decoder, Streaming},
325 decoder: impl Decoder<Item = M2, Error = Status> + Send + 'static, in create_response()
/tonic/
H A DCHANGELOG.md592 * **codec:** Introduce `Decoder/Encoder` traits ([#208](https://github.com/hyperium/tonic/issues/20…
601 * **codec:** Add new `Decoder/Encoder` traits and use `EncodeBuf/DecodeBuf` over `BytesMut` directl…