Home
last modified time | relevance | path

Searched refs:req (Results 1 – 25 of 51) sorted by relevance

123

/tonic/tests/web/src/
H A Dlib.rs18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
19 let req = req.into_inner(); in unary_call() localVariable
21 if &req.desc == "boom" { in unary_call()
25 id: req.id, in unary_call()
26 desc: req.desc, in unary_call()
35 req: Request<Input>, in server_stream()
37 let req = req.into_inner(); in server_stream() localVariable
42 id: req.id, in server_stream()
43 desc: format!("{}-{}", n, req.desc), in server_stream()
51 req: Request<Streaming<Input>>, in client_stream()
[all …]
/tonic/tonic-web/src/
H A Dservice.rs61 match RequestKind::new(req.headers(), req.method(), req.version()) { in call()
213 req.headers_mut() in coerce_request()
216 req.headers_mut() in coerce_request()
219 req.headers_mut().insert( in coerce_request()
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
359 req.headers_mut() in grpc_web_content_types()
406 let req = request(); in h2_is_ok() localVariable
416 let req = Request::builder() in h1_is_err() localVariable
[all …]
H A Dclient.rs63 fn call(&mut self, mut req: Request<B1>) -> Self::Future { in call()
64 if req.version() == Version::HTTP_2 { in call()
67 *req.version_mut() = Version::HTTP_11; in call()
70 req.headers_mut() in call()
73 let req = req.map(GrpcWebCall::client_request); in call() localVariable
75 let fut = self.inner.call(req); in call()
/tonic/tests/integration_tests/tests/
H A Dtimeout.rs14 let mut req = Request::new(Input {}); in cancelation_on_timeout() localVariable
15 req.metadata_mut() in cancelation_on_timeout()
19 let res = client.unary_call(req).await; in cancelation_on_timeout()
34 let mut req = Request::new(Input {}); in picks_server_timeout_if_thats_sorter() localVariable
35 req.metadata_mut() in picks_server_timeout_if_thats_sorter()
39 let res = client.unary_call(req).await; in picks_server_timeout_if_thats_sorter()
53 let mut req = Request::new(Input {}); in picks_client_timeout_if_thats_sorter() localVariable
54 req.metadata_mut() in picks_client_timeout_if_thats_sorter()
58 let res = client.unary_call(req).await; in picks_client_timeout_if_thats_sorter()
H A Dextensions.rs27 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_interceptor()
28 let value = req.extensions().get::<ExtensionValue>().unwrap(); in setting_extension_from_interceptor()
35 let svc = test_server::TestServer::with_interceptor(Svc, |mut req: Request<()>| { in setting_extension_from_interceptor()
36 req.extensions_mut().insert(ExtensionValue(42)); in setting_extension_from_interceptor()
37 Ok(req) in setting_extension_from_interceptor()
77 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_tower()
78 let value = req.extensions().get::<ExtensionValue>().unwrap(); in setting_extension_from_tower()
142 fn call(&mut self, mut req: http::Request<Body>) -> Self::Future { in call()
146 req.extensions_mut().insert(ExtensionValue(42)); in call()
149 let response = inner.call(req).await?; in call()
H A Dconnect_info.rs18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in getting_connect_info()
19 assert!(req.local_addr().is_some()); in getting_connect_info()
20 assert!(req.remote_addr().is_some()); in getting_connect_info()
21 assert!(req.extensions().get::<TcpConnectInfo>().is_some()); in getting_connect_info()
82 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
83 let conn_info = req.extensions().get::<UdsConnectInfo>().unwrap(); in unary_call()
86 assert!(req.local_addr().is_none()); in unary_call()
87 assert!(req.remote_addr().is_none()); in unary_call()
H A Dinterceptor.rs43 fn client_intercept(req: Request<()>) -> Result<Request<()>, Status> { in interceptor_retrieves_grpc_method()
44 println!("Intercepting client request: {:?}", req); in interceptor_retrieves_grpc_method()
46 let gm = req.extensions().get::<GrpcMethod>().unwrap(); in interceptor_retrieves_grpc_method()
50 Ok(req) in interceptor_retrieves_grpc_method()
/tonic/tests/compression/src/
H A Dclient_stream.rs40 req in client_enabled_server_enabled()
50 .map_request(move |req| { in client_enabled_server_enabled()
70 let req = Request::new(Box::pin(stream)); in client_enabled_server_enabled() localVariable
72 client.compress_input_client_stream(req).await.unwrap(); in client_enabled_server_enabled()
94 assert!(req.headers().get("grpc-encoding").is_none()); in client_disabled_server_enabled()
95 req in client_disabled_server_enabled()
121 let req = Request::new(Box::pin(stream)); in client_disabled_server_enabled() localVariable
123 client.compress_input_client_stream(req).await.unwrap(); in client_disabled_server_enabled()
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
[all …]
H A Dbidirectional_stream.rs34 pub fn call<B: Body>(self, req: http::Request<B>) -> http::Request<B> { in client_enabled_server_enabled()
41 assert_eq!(req.headers().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled()
43 req in client_enabled_server_enabled()
54 .map_request(move |req| { in client_enabled_server_enabled()
55 AssertRightEncoding::new(encoding).clone().call(req) in client_enabled_server_enabled()
81 let req = Request::new(stream); in client_enabled_server_enabled() localVariable
84 .compress_input_output_bidirectional_stream(req) in client_enabled_server_enabled()
H A Dlib.rs57 async fn compress_input_unary(&self, req: Request<SomeData>) -> Result<Response<()>, Status> { in compress_input_unary()
58 assert_eq!(req.into_inner().data.len(), UNCOMPRESSED_MIN_BODY_SIZE); in compress_input_unary()
78 req: Request<Streaming<SomeData>>, in compress_input_client_stream()
80 let mut stream = req.into_inner(); in compress_input_client_stream()
89 req: Request<Streaming<SomeData>>, in compress_output_client_stream()
91 let mut stream = req.into_inner(); in compress_output_client_stream()
108 req: Request<Streaming<SomeData>>, in compress_input_output_bidirectional_stream()
110 let mut stream = req.into_inner(); in compress_input_output_bidirectional_stream()
H A Dcompressing_request.rs31 pub fn call<B: Body>(self, req: http::Request<B>) -> http::Request<B> { in client_enabled_server_enabled()
38 assert_eq!(req.headers().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled()
40 req in client_enabled_server_enabled()
52 .map_request(move |req| { in client_enabled_server_enabled()
53 AssertRightEncoding::new(encoding).clone().call(req) in client_enabled_server_enabled()
100 fn assert_right_encoding<B>(req: http::Request<B>) -> http::Request<B> { in client_enabled_server_enabled_multi_encoding()
102 let req_encoding = req.headers().get("grpc-encoding").unwrap(); in client_enabled_server_enabled_multi_encoding()
105 req in client_enabled_server_enabled_multi_encoding()
220 move |mut req: Request<()>| { in client_mark_compressed_without_header_server_enabled()
221 req.metadata_mut().remove("grpc-encoding"); in client_mark_compressed_without_header_server_enabled()
[all …]
/tonic/interop/src/
H A Dserver.rs32 let req = request.into_inner(); in unary_call() localVariable
39 let res_size = if req.response_size >= 0 { in unary_call()
40 req.response_size as usize in unary_call()
65 req: Request<StreamingOutputCallRequest>, in streaming_output_call()
70 } = req.into_inner(); in streaming_output_call()
88 req: Streaming<StreamingInputCallRequest>, in streaming_input_call()
90 let mut stream = req.into_inner(); in streaming_input_call()
108 req: Streaming<StreamingOutputCallRequest>, in full_duplex_call()
110 let mut stream = req.into_inner(); in full_duplex_call()
200 let echo_trailer = req in call()
[all …]
/tonic/tonic-reflection/src/server/
H A Dv1alpha.rs28 req: Request<Streaming<ServerReflectionRequest>>, in server_reflection_info()
30 let mut req_rx = req.into_inner(); in server_reflection_info()
36 while let Some(req) = req_rx.next().await { in server_reflection_info()
37 let Ok(req) = req else { in server_reflection_info()
41 let resp_msg = match req.message_request.clone() { in server_reflection_info()
81 valid_host: req.host.clone(), in server_reflection_info()
82 original_request: Some(req.clone()), in server_reflection_info()
H A Dv1.rs28 req: Request<Streaming<ServerReflectionRequest>>, in server_reflection_info()
30 let mut req_rx = req.into_inner(); in server_reflection_info()
36 while let Some(req) = req_rx.next().await { in server_reflection_info()
37 let Ok(req) = req else { in server_reflection_info()
41 let resp_msg = match req.message_request.clone() { in server_reflection_info()
81 valid_host: req.host.clone(), in server_reflection_info()
82 original_request: Some(req.clone()), in server_reflection_info()
/tonic/tonic/src/server/
H A Dgrpc.rs222 req: http::Request<B>, in unary()
230 req.headers(), in unary()
265 req: http::Request<B>, in server_streaming()
274 req.headers(), in server_streaming()
306 req: http::Request<B>, in client_streaming()
314 req.headers(), in client_streaming()
318 let request = t!(self.map_request_streaming(req)); in client_streaming()
339 req: http::Request<B>, in streaming()
348 req.headers(), in streaming()
391 req.metadata_mut().merge(trailers); in map_request_unary()
[all …]
/tonic/examples/src/interceptor/
H A Dserver.rs49 fn intercept(mut req: Request<()>) -> Result<Request<()>, Status> { in intercept()
50 println!("Intercepting request: {:?}", req); in intercept()
53 req.extensions_mut().insert(MyExtension { in intercept()
57 Ok(req) in intercept()
/tonic/examples/src/authentication/
H A Dclient.rs14 let mut client = EchoClient::with_interceptor(channel, move |mut req: Request<()>| { in main()
15 req.metadata_mut().insert("authorization", token.clone()); in main()
16 Ok(req) in main()
H A Dserver.rs33 fn check_auth(req: Request<()>) -> Result<Request<()>, Status> { in check_auth()
36 match req.metadata().get("authorization") { in check_auth()
37 Some(t) if token == t => Ok(req), in check_auth()
/tonic/examples/src/tower/
H A Dclient.rs36 fn intercept(req: Request<()>) -> Result<Request<()>, Status> { in intercept()
37 println!("received {:?}", req); in intercept()
38 Ok(req) in intercept()
70 fn call(&mut self, req: Request<Body>) -> Self::Future { in call()
77 let response = inner.call(req).await?; in call()
/tonic/tonic/src/service/
H A Dinterceptor.rs129 fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future { in call()
135 let uri = req.uri().clone(); in call()
136 let method = req.method().clone(); in call()
137 let version = req.version(); in call()
138 let req = crate::Request::from_http(req); in call() localVariable
139 let (metadata, extensions, msg) = req.into_parts(); in call()
145 Ok(req) => { in call()
146 let (metadata, extensions, _) = req.into_parts(); in call()
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
[all …]
/tonic/examples/src/h2c/
H A Dserver.rs100 fn call(&mut self, req: hyper::Request<Incoming>) -> Self::Future { in call()
101 let mut req = req.map(Body::new); in call() localVariable
105 .map_request(|req: Request<_>| req.map(Body::new)); in call()
108 let upgraded_io = hyper::upgrade::on(&mut req).await.unwrap(); in call()
/tonic/tests/use_arc_self/src/
H A Dlib.rs16 req: Request<SomeData>, in test_request()
18 Ok(Response::new(req.into_inner())) in test_request()
/tonic/examples/src/gcp/
H A Dclient.rs39 let mut service = PublisherClient::with_interceptor(channel, move |mut req: Request<()>| { in main()
40 req.metadata_mut() in main()
42 Ok(req) in main()
/tonic/tonic-build/src/
H A Dclient.rs245 let mut req = request.into_request(); in generate_unary() localVariable
246 req.extensions_mut().insert(GrpcMethod::new(#service_name, #method_name)); in generate_unary()
247 self.inner.unary(req, path, codec).await in generate_unary()
276 let mut req = request.into_request(); in generate_server_streaming() localVariable
277 req.extensions_mut().insert(GrpcMethod::new(#service_name, #method_name)); in generate_server_streaming()
278 self.inner.server_streaming(req, path, codec).await in generate_server_streaming()
307 let mut req = request.into_streaming_request(); in generate_client_streaming() localVariable
309 self.inner.client_streaming(req, path, codec).await in generate_client_streaming()
338 let mut req = request.into_streaming_request(); in generate_streaming() localVariable
339 req.extensions_mut().insert(GrpcMethod::new(#service_name,#method_name)); in generate_streaming()
[all …]
/tonic/examples/src/streaming/
H A Dserver.rs48 req: Request<EchoRequest>, in server_streaming_echo()
51 println!("\tclient connected from: {:?}", req.remote_addr()); in server_streaming_echo()
55 message: req.into_inner().message, in server_streaming_echo()
94 req: Request<Streaming<EchoRequest>>, in bidirectional_streaming_echo()
98 let mut in_stream = req.into_inner(); in bidirectional_streaming_echo()

123