Searched refs:DecodeBuf (Results 1 – 7 of 7) sorted by relevance
| /tonic/tonic/src/codec/ |
| H A D | buffer.rs | 6 pub struct DecodeBuf<'a> { struct
17 impl<'a> DecodeBuf<'a> { argument
19 DecodeBuf { buf, len } in new()
23 impl Buf for DecodeBuf<'_> { implementation
116 let mut buf = DecodeBuf::new(&mut payload, 20); in decode_buf()
|
| H A D | mod.rs | 16 pub use self::buffer::{DecodeBuf, EncodeBuf};
153 fn decode(&mut self, src: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error>; in decode()
|
| H A D | prost.rs | 1 use super::{BufferSettings, Codec, DecodeBuf, Decoder, Encoder};
131 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode()
154 DecodeBuf, Decoder, EncodeBody, EncodeBuf, Encoder, Streaming, HEADER_SIZE,
338 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode()
|
| H A D | decode.rs | 2 use super::{BufferSettings, DecodeBuf, Decoder, DEFAULT_MAX_RECV_MESSAGE_SIZE, HEADER_SIZE};
150 ) -> Result<Option<DecodeBuf<'_>>, Status> { in decode_chunk()
236 DecodeBuf::new(&mut self.decompress_buf, decompressed_len) in decode_chunk()
238 DecodeBuf::new(&mut self.buf, len) in decode_chunk()
|
| /tonic/examples/src/json-codec/ |
| H A D | common.rs | 9 codec::{Codec, DecodeBuf, Decoder, EncodeBuf, Encoder},
42 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode()
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 11 use tonic::{codec::DecodeBuf, codec::Decoder, Status, Streaming};
106 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode()
|
| /tonic/ |
| H A D | CHANGELOG.md | 601 * **codec:** Add new `Decoder/Encoder` traits and use `EncodeBuf/DecodeBuf` over `BytesMut` directl…
|