| /tonic/tests/compression/src/ |
| H A D | server_stream.rs | 32 .into_inner(), in client_enabled_server_enabled()
54 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_enabled()
97 .into_inner(), in client_disabled_server_enabled()
112 let mut stream: Streaming<SomeData> = res.into_inner(); in client_disabled_server_enabled()
149 .into_inner(), in client_enabled_server_disabled()
165 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_disabled()
|
| H A D | lib.rs | 58 assert_eq!(req.into_inner().data.len(), UNCOMPRESSED_MIN_BODY_SIZE); in compress_input_unary()
80 let mut stream = req.into_inner(); in compress_input_client_stream()
91 let mut stream = req.into_inner(); in compress_output_client_stream()
110 let mut stream = req.into_inner(); in compress_input_output_bidirectional_stream()
|
| H A D | compressing_response.rs | 75 .into_inner(), in client_enabled_server_enabled()
130 .into_inner(), in client_enabled_server_disabled()
171 .into_inner(), in client_enabled_server_disabled_multi_encoding()
245 .into_inner(), in client_disabled()
289 .into_inner(), in server_replying_with_unsupported_encoding()
338 .into_inner(), in disabling_compression_on_single_response()
396 .into_inner(), in disabling_compression_on_response_but_keeping_compression_on_stream()
418 let mut stream: Streaming<SomeData> = res.into_inner(); in disabling_compression_on_response_but_keeping_compression_on_stream()
465 .into_inner(), in disabling_compression_on_response_from_client_stream()
|
| H A D | compressing_request.rs | 56 .into_inner(), in client_enabled_server_enabled()
58 .into_inner(), in client_enabled_server_enabled()
118 .into_inner(), in client_enabled_server_enabled_multi_encoding()
120 .into_inner(), in client_enabled_server_enabled_multi_encoding()
|
| H A D | bidirectional_stream.rs | 66 .into_inner(), in client_enabled_server_enabled()
96 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_enabled()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | routes_builder.rs | 34 buf: request.into_inner().buf, in multiple_service_using_routes_builder()
45 buf: request.into_inner().buf, in multiple_service_using_routes_builder()
91 .into_inner(); in multiple_service_using_routes_builder()
99 .into_inner(); in multiple_service_using_routes_builder()
|
| /tonic/examples/src/streaming/ |
| H A D | client.rs | 24 .into_inner(); in streaming_echo()
42 let mut resp_stream = response.into_inner(); in bidirectional_streaming_echo()
58 let mut resp_stream = response.into_inner(); in bidirectional_streaming_echo_throttle()
|
| H A D | server.rs | 55 message: req.into_inner().message, in server_streaming_echo()
98 let mut in_stream = req.into_inner(); in bidirectional_streaming_echo()
|
| /tonic/tests/web/src/ |
| H A D | lib.rs | 19 let req = req.into_inner(); in unary_call()
37 let req = req.into_inner(); in server_stream()
59 req.into_inner() in client_stream()
|
| /tonic/examples/src/grpc-web/ |
| H A D | server.rs | 22 message: format!("Hello {}!", request.into_inner().name), in say_hello()
38 .into_inner() in main()
|
| /tonic/examples/src/multiplex/ |
| H A D | server.rs | 47 message: format!("Hello {}!", request.into_inner().name), in say_hello()
62 let message = request.into_inner().message; in unary_echo()
|
| /tonic/interop/src/ |
| H A D | client.rs | 31 let body = response.into_inner(); in empty_unary()
59 let body = response.into_inner(); in large_unary()
101 let body = response.into_inner(); in client_streaming()
131 .into_inner() in server_streaming()
169 if let Ok(mut response) = result.map(Response::into_inner) { in ping_pong()
219 if let Ok(response) = result.map(Response::into_inner) { in empty_stream()
276 let stream = response.into_inner(); in status_code_and_message()
391 let mut stream = response.into_inner(); in custom_metadata()
|
| H A D | server.rs | 32 let req = request.into_inner(); in unary_call()
70 } = req.into_inner(); in streaming_output_call()
90 let mut stream = req.into_inner(); in streaming_input_call()
110 let mut stream = req.into_inner(); in full_duplex_call()
|
| /tonic/examples/src/routeguide/ |
| H A D | client.rs | 32 .into_inner(); in print_features()
54 Ok(response) => println!("SUMMARY: {:?}", response.into_inner()), in run_record_route()
83 let mut inbound = response.into_inner(); in run_route_chat()
|
| /tonic/examples/src/dynamic/ |
| H A D | server.rs | 28 let message = format!("you said: {}", request.into_inner().message); in unary_echo()
55 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/tests/use_arc_self/src/ |
| H A D | lib.rs | 18 Ok(Response::new(req.into_inner())) in test_request()
|
| /tonic/tonic-health/src/ |
| H A D | server.rs | 232 let resp = resp.unwrap().into_inner(); in test_service_check()
251 let resp = resp.unwrap().into_inner(); in test_service_check()
264 let resp = resp.unwrap().into_inner(); in test_service_check()
279 let mut resp = resp.unwrap().into_inner(); in test_service_watch()
303 let mut resp = resp.unwrap().into_inner(); in test_service_watch()
|
| /tonic/examples/src/tower/ |
| H A D | server.rs | 27 message: format!("Hello {}!", request.into_inner().name), in say_hello()
48 .into_inner(); in main()
|
| /tonic/tonic/src/transport/ |
| H A D | tls.rs | 34 pub fn into_inner(self) -> Vec<u8> { in into_inner() method
|
| /tonic/examples/src/codec_buffers/ |
| H A D | server.rs | 32 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/helloworld/ |
| H A D | server.rs | 22 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/blocking/ |
| H A D | server.rs | 24 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/json-codec/ |
| H A D | server.rs | 29 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/compression/ |
| H A D | server.rs | 23 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/reflection/ |
| H A D | server.rs | 23 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|