| /tonic/tests/integration_tests/tests/ |
| H A D | timeout.rs | 14 let mut req = Request::new(Input {}); in cancelation_on_timeout() localVariable
34 let mut req = Request::new(Input {}); in picks_server_timeout_if_thats_sorter() localVariable
53 let mut req = Request::new(Input {}); in picks_client_timeout_if_thats_sorter() localVariable
|
| H A D | max_message_size.rs | 180 let req = Request::new(Input1 { in response_stream_limit() localVariable
356 let req = Request::new(Input1 { in max_message_run() localVariable
|
| /tonic/tests/compression/src/ |
| H A D | client_stream.rs | 70 let req = Request::new(Box::pin(stream)); in client_enabled_server_enabled() localVariable
121 let req = Request::new(Box::pin(stream)); in client_disabled_server_enabled() localVariable
155 let req = Request::new(Box::pin(stream)); in client_enabled_server_disabled() localVariable
214 let req = Request::new(Box::pin(tokio_stream::empty())); in compressing_response_from_client_stream() localVariable
|
| H A D | bidirectional_stream.rs | 81 let req = Request::new(stream); in client_enabled_server_enabled() localVariable
|
| H A D | compressing_response.rs | 477 let req = Request::new(Box::pin(tokio_stream::empty())); in disabling_compression_on_response_from_client_stream() localVariable
|
| /tonic/tests/web/src/ |
| H A D | lib.rs | 19 let req = req.into_inner(); in unary_call() localVariable
37 let req = req.into_inner(); in server_stream() localVariable
|
| /tonic/tonic-web/src/ |
| H A D | service.rs | 320 let mut req = request(); in without_origin() localVariable
339 let mut req = request(); in only_post_and_options_allowed() localVariable
358 let mut req = request(); in grpc_web_content_types() localVariable
406 let req = request(); in h2_is_ok() localVariable
416 let req = Request::builder() in h1_is_err() localVariable
430 let mut req = request(); in content_type_variants() localVariable
464 let mut req = request(); in h2_is_ok() localVariable
|
| H A D | client.rs | 73 let req = req.map(GrpcWebCall::client_request); in call() localVariable
|
| /tonic/interop/src/ |
| H A D | client.rs | 43 let req = SimpleRequest { in large_unary() localVariable
112 let req = StreamingOutputCallRequest { in server_streaming() localVariable
119 let req = Request::new(req); in server_streaming() localVariable
287 let req = SimpleRequest { in special_status_message() localVariable
349 let req = SimpleRequest { in custom_metadata() localVariable
|
| H A D | server.rs | 32 let req = request.into_inner(); in unary_call() localVariable
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 27 let req = build_request(server_url, "grpc-web", "grpc-web"); in binary_request() localVariable
50 let req = build_request(server_url, "grpc-web-text", "grpc-web-text"); in text_request() localVariable
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 245 let mut req = request.into_request(); in generate_unary() localVariable
276 let mut req = request.into_request(); in generate_server_streaming() localVariable
307 let mut req = request.into_streaming_request(); in generate_client_streaming() localVariable
338 let mut req = request.into_streaming_request(); in generate_streaming() localVariable
|
| /tonic/tonic/src/service/ |
| H A D | interceptor.rs | 138 let req = crate::Request::from_http(req); in call() localVariable
147 let req = crate::Request::from_parts(metadata, extensions, msg); in call() localVariable
148 let req = req.into_http(uri, method, version, SanitizeHeaders::No); in call() localVariable
|
| /tonic/examples/src/h2c/ |
| H A D | server.rs | 101 let mut req = req.map(Body::new); in call() localVariable
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 159 let mut req = request.into_request(); in check() localVariable
198 let mut req = request.into_request(); in watch() localVariable
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 388 let mut req = Request::from_http_parts(parts, message); in map_request_unary() localVariable
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 250 let mut req = request.into_streaming_request(); in server_reflection_info() localVariable
|
| H A D | grpc_reflection_v1alpha.rs | 250 let mut req = request.into_streaming_request(); in server_reflection_info() localVariable
|