| /tonic/tonic/benches-disabled/benchmarks/ |
| H A D | request_response.rs | 36 .iter() in bench_throughput()
41 b.iter(|| build_request(i.to_string())) in bench_throughput()
44 b.iter(|| build_response(i.to_string())) in bench_throughput()
|
| H A D | request_response_diverse_types.rs | 87 for size in [tiny_string, short_string, medium_string].iter() { in bench_throughput()
91 b.iter(|| build_request(i.to_string())) in bench_throughput()
|
| /tonic/examples/src/health/ |
| H A D | server.rs | 33 let mut iter = 0u64; in twiddle_service_status() localVariable
35 iter += 1; in twiddle_service_status()
38 if iter % 2 == 0 { in twiddle_service_status()
|
| /tonic/interop/src/ |
| H A D | lib.rs | 12 use std::{default, fmt, iter};
21 body: iter::repeat_n(0u8, size).collect(), in client_payload()
28 body: iter::repeat_n(0u8, size).collect(), in server_payload()
49 responses.iter().map(&response_length).collect() in response_lengths()
|
| H A D | client.rs | 85 let requests = REQUEST_LENGTHS.iter().map(|len| StreamingInputCallRequest { in client_streaming()
90 let stream = tokio_stream::iter(requests); in client_streaming()
114 .iter() in server_streaming()
|
| /tonic/tests/compression/src/ |
| H A D | lib.rs | 70 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_output_server_stream()
116 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_input_output_bidirectional_stream()
|
| H A D | client_stream.rs | 69 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled()
120 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_disabled_server_enabled()
154 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_disabled()
|
| H A D | compressing_request.rs | 61 .serve_with_incoming(tokio_stream::iter(vec![Ok::<_, std::io::Error>(server)])) in client_enabled_server_enabled()
103 assert!(supported_encodings.iter().any(|e| e == req_encoding)); in client_enabled_server_enabled_multi_encoding()
|
| H A D | bidirectional_stream.rs | 80 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled()
|
| /tonic/tonic-types/src/richer_error/ |
| H A D | mod.rs | 763 for any in self.details.iter() { in check_error_details()
809 for any in self.details.iter() { in check_error_details_vec()
853 for any in self.details.iter() { in get_details_retry_info()
865 for any in self.details.iter() { in get_details_debug_info()
877 for any in self.details.iter() { in get_details_quota_failure()
889 for any in self.details.iter() { in get_details_error_info()
901 for any in self.details.iter() { in get_details_precondition_failure()
913 for any in self.details.iter() { in get_details_bad_request()
925 for any in self.details.iter() { in get_details_request_info()
937 for any in self.details.iter() { in get_details_resource_info()
[all …]
|
| /tonic/tonic-build/src/ |
| H A D | prost.rs | 85 .iter() in new()
175 || NON_PATH_TYPE_ALLOWLIST.iter().any(|ty| *ty == rust_type) in request_response_name()
621 for path in protos.iter() { in compile_protos_with_config()
625 for path in includes.iter() { in compile_protos_with_config()
662 for (proto_path, rust_path) in self.extern_path.iter() { in setup_config()
665 for (prost_path, attr) in self.field_attributes.iter() { in setup_config()
668 for (prost_path, attr) in self.type_attributes.iter() { in setup_config()
671 for (prost_path, attr) in self.message_attributes.iter() { in setup_config()
674 for (prost_path, attr) in self.enum_attributes.iter() { in setup_config()
677 for prost_path in self.boxed.iter() { in setup_config()
[all …]
|
| /tonic/tests/web/ |
| H A D | build.rs | 9 .iter() in main()
|
| /tonic/tonic/src/codec/ |
| H A D | prost.rs | 228 let messages = std::iter::repeat_with(move || Ok::<_, Status>(msg.clone())).take(10000); in encode()
229 let source = tokio_stream::iter(messages); in encode()
250 let messages = std::iter::once(Ok::<_, Status>(msg)); in encode_max_message_size_exceeded()
251 let source = tokio_stream::iter(messages); in encode_max_message_size_exceeded()
287 let messages = std::iter::once(Ok::<_, Status>(msg)); in encode_too_big()
288 let source = tokio_stream::iter(messages); in encode_too_big()
|
| /tonic/examples/src/dynamic/ |
| H A D | server.rs | 35 let enabled = args.iter().any(|arg| arg.as_str() == "echo"); in init_echo()
62 let enabled = args.iter().any(|arg| arg.as_str() == "greeter"); in init_greeter()
|
| /tonic/examples/src/load_balance/ |
| H A D | client.rs | 11 .iter() in main()
|
| /tonic/codegen/src/ |
| H A D | main.rs | 81 let iface_files = iface_files.iter().map(|&path| root_dir.join(path)); in codegen()
82 let include_dirs = include_dirs.iter().map(|&path| root_dir.join(path)); in codegen()
|
| /tonic/examples/src/richer-error/ |
| H A D | client_vec.rs | 30 for (i, err_detail) in err_details.iter().enumerate() { in main()
|
| /tonic/examples/src/streaming/ |
| H A D | server.rs | 54 let repeat = std::iter::repeat(EchoResponse { in server_streaming_echo()
57 let mut stream = Box::pin(tokio_stream::iter(repeat).throttle(Duration::from_millis(200))); in server_streaming_echo()
|
| H A D | client.rs | 12 tokio_stream::iter(1..usize::MAX).map(|i| EchoRequest { in echo_requests_iter()
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 24 b.iter(|| {
86 let sample = self.data.iter().take(10).collect::<Vec<_>>(); in fmt()
|
| /tonic/tonic/src/metadata/ |
| H A D | map.rs | 727 pub fn iter(&self) -> Iter<'_> { in iter() method
729 inner: self.headers.iter(), in iter()
823 inner: self.headers.iter(), in values()
1881 pub fn iter(&self) -> ValueIter<'_, VE> { in iter() method
1883 inner: Some(self.inner.iter()), in iter()
1940 self.iter() in into_iter()
1974 pub fn iter(&self) -> ValueIter<'a, VE> { in iter() method
1976 inner: self.inner.as_ref().map(|inner| inner.iter()), in iter()
1984 self.inner.iter().eq(other.inner.iter()) in eq()
2546 for key_and_value in map.iter() { in test_iter_categorizes_ascii_entries()
[all …]
|
| /tonic/tests/web/src/ |
| H A D | lib.rs | 39 Ok(Response::new(Box::pin(stream::iter(vec![1, 2]).map( in server_stream()
|
| /tonic/tests/default_stubs/src/ |
| H A D | test_defaults.rs | 10 tokio_stream::iter(1..usize::MAX).map(|_| ()) in echo_requests_iter()
|
| /tonic/examples/src/routeguide/ |
| H A D | client.rs | 51 let request = Request::new(tokio_stream::iter(points)); in run_record_route()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | status.rs | 156 let s = tokio_stream::iter(vec![ in status_from_server_stream()
226 let s = tokio_stream::iter(vec![ in message_and_then_status_from_server_stream()
|