Searched refs:decoder (Results 1 – 8 of 8) sorted by relevance
| /tonic/tonic/src/codec/ |
| H A D | decode.rs | 22 decoder: Box<dyn Decoder<Item = T, Error = Status> + Send + 'static>, field
60 decoder: D, in new_response()
72 decoder, in new_response()
81 pub fn new_empty<B, D>(decoder: D, body: B) -> Self in new_empty()
87 Self::new(decoder, body, Direction::EmptyResponse, None, None) in new_empty()
93 decoder: D, in new_request()
104 decoder, in new_request()
113 decoder: D, in new()
124 let buffer_size = decoder.buffer_settings().buffer_size; in new()
126 decoder: Box::new(decoder), in new()
[all …]
|
| H A D | prost.rs | 69 fn decoder(&mut self) -> Self::Decoder { in decoder() function
168 let decoder = MockDecoder::default(); in decode() localVariable
182 let mut stream = Streaming::new_request(decoder, body, None, None); in decode()
194 let decoder = MockDecoder::default(); in decode_max_message_size_exceeded() localVariable
208 let mut stream = Streaming::new_request(decoder, body, None, Some(MAX_MESSAGE_SIZE)); in decode_max_message_size_exceeded()
|
| H A D | mod.rs | 118 fn decoder(&mut self) -> Self::Decoder; in decoder() method
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 316 let decoder = codec.decoder(); in streaming() localVariable
318 self.create_response(decoder, response) in streaming()
325 decoder: impl Decoder<Item = M2, Error = Status> + Send + 'static, in create_response()
356 decoder, in create_response()
363 Streaming::new_empty(decoder, body) in create_response()
|
| /tonic/examples/src/codec_buffers/ |
| H A D | common.rs | 38 fn decoder(&mut self) -> Self::Decoder { in decoder() function
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 26 let decoder = MockDecoder::new($message_size); localVariable
27 let mut stream = Streaming::new_request(decoder, body.clone(), None, None);
|
| /tonic/examples/src/json-codec/ |
| H A D | common.rs | 77 fn decoder(&mut self) -> Self::Decoder { in decoder() function
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 377 self.codec.decoder(), in map_request_unary()
409 self.codec.decoder(), in map_request_streaming()
|