| /tonic/tests/compression/src/ |
| H A D | lib.rs | 50 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE]; in compress_output_unary() localVariable
53 data: data.to_vec(), in compress_output_unary()
58 assert_eq!(req.into_inner().data.len(), UNCOMPRESSED_MIN_BODY_SIZE); in compress_input_unary()
69 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in compress_output_server_stream() localVariable
70 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_output_server_stream()
96 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE]; in compress_output_client_stream() localVariable
99 data: data.to_vec(), in compress_output_client_stream()
115 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in compress_input_output_bidirectional_stream() localVariable
116 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_input_output_bidirectional_stream()
|
| H A D | client_stream.rs | 68 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in client_enabled_server_enabled() localVariable
69 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled()
119 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in client_disabled_server_enabled() localVariable
120 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_disabled_server_enabled()
153 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in client_enabled_server_disabled() localVariable
154 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_disabled()
|
| H A D | bidirectional_stream.rs | 79 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in client_enabled_server_enabled() localVariable
80 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled()
|
| H A D | compressing_request.rs | 73 data: [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(), in client_enabled_server_enabled()
135 data: [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(), in client_enabled_server_enabled_multi_encoding()
170 data: [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(), in client_enabled_server_disabled()
229 data: [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(), in client_mark_compressed_without_header_server_enabled()
|
| H A D | util.rs | 78 if let Some(data) = frame.data_ref() { in frame_data_length()
79 data.len() in frame_data_length()
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 45 data: Bytes, field
50 fn new(data: Bytes, chunk_size: usize) -> Self { in new()
51 MockBody { data, chunk_size } in new()
55 self.data.len() in len()
67 if self.data.has_remaining() { in poll_frame()
68 let split = std::cmp::min(self.chunk_size, self.data.remaining()); in poll_frame()
69 Poll::Ready(Some(Ok(Frame::data(self.data.split_to(split))))) in poll_frame()
76 !self.data.is_empty() in is_end_stream()
80 SizeHint::with_exact(self.data.len() as u64) in size_hint()
86 let sample = self.data.iter().take(10).collect::<Vec<_>>(); in fmt()
[all …]
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 29 assert!(data(&r1) == data(&r2) && data(&r2) == data(&r3) && data(&r3) == data(&r4)); in smoke_unary()
47 assert!(data(&r1) == data(&r2) && data(&r2) == data(&r3) && data(&r3) == data(&r4)); in smoke_client_stream()
155 fn data<T>(r: &Response<T>) -> &T { in data() function
|
| /tonic/tests/use_arc_self/proto/ |
| H A D | test.proto | 10 // include a bunch of data so there actually is something to compress
11 bytes data = 1; field
|
| /tonic/tests/compression/proto/ |
| H A D | test.proto | 17 // include a bunch of data so there actually is something to compress
18 bytes data = 1; field
|
| /tonic/tonic/src/codec/ |
| H A D | prost.rs | 360 data: Bytes, field
372 data: Bytes::copy_from_slice(b), in new()
389 let data_len = self.data.len(); in poll_frame()
395 self.data in poll_frame()
397 Poll::Ready(Some(Ok(Frame::data(response)))) in poll_frame()
|
| H A D | encode.rs | 321 Some(Ok(d)) => Some(Ok(Frame::data(d))).into(), in poll_frame()
|
| /tonic/tonic-web/src/ |
| H A D | call.rs | 177 return Poll::Ready(Some(Ok(Frame::data(bytes)))); in poll_decode()
224 let mut data = frame.into_data().unwrap_or_else(|_| unreachable!()); in poll_encode() localVariable
225 let mut res = data.copy_to_bytes(data.remaining()); in poll_encode()
231 Poll::Ready(Some(Ok(Frame::data(res)))) in poll_encode()
241 Poll::Ready(Some(Ok(Frame::data(res)))) in poll_encode()
307 Poll::Ready(Some(Ok(Frame::data(msg_buf)))) in poll_frame()
317 _ => Some(Ok(Frame::data(buf.split_to(len).freeze()))), in poll_frame()
|
| /tonic/examples/ |
| H A D | routeguide-tutorial.md | 324 Create the json data file and a helper module to read and deserialize our features.
327 $ mkdir data && touch data/route_guide_db.json
328 $ touch src/data.rs
331 You can find our example json data in [examples/data/route_guide_db.json][route-guide-db] and
332 the corresponding `data` module to load and deserialize it in
333 [examples/routeguide/data.rs][data-module].
335 **Note:** If you are following along, you'll need to change the data file's path from
336 `examples/data/route_guide_db.json` to `data/route_guide_db.json`.
364 [data-module]: https://github.com/hyperium/tonic/blob/master/examples/src/routeguide/data.rs
534 mod data;
[all …]
|
| /tonic/examples/src/routeguide/ |
| H A D | server.rs | 18 mod data; module
141 features: Arc::new(data::load()), in main()
|
| /tonic/tonic-types/proto/ |
| H A D | status.proto | 31 // three pieces of data: error code, error message, and error details.
|
| H A D | error_details.proto | 193 // Any data that was used to serve this request. For example, an encrypted
|
| /tonic/interop/proto/grpc/testing/ |
| H A D | messages.proto | 36 // A block of data, to simply increase gRPC message size.
39 // The type of data in body.
|
| /tonic/examples/proto/googleapis/google/pubsub/v1/ |
| H A D | pubsub.proto | 204 // message must contain either a non-empty data field or at least one attribute.
212 // The message data field. If this field is empty, the message must contain
214 bytes data = 1; field
217 // contain non-empty data. This can be used to filter messages on the
302 // return the next page of data.
330 // that the system should return the next page of data.
361 // that the system should return the next page of data.
843 // indicates the version of the data expected by the endpoint. This
939 // system should return the next page of data.
1258 // should return the next page of data.
|
| H A D | schema.proto | 203 // system should return the next page of data.
|
| /tonic/examples/proto/googleapis/google/api/ |
| H A D | http.proto | 180 // which don't use the URL at all for transferring data.
|
| /tonic/ |
| H A D | CONTRIBUTING.md | 387 the commit log, or by using an `Author: ` meta-data tag in the commit.
|