Home
last modified time | relevance | path

Searched refs:Request (Results 1 – 25 of 118) sorted by relevance

12345

/tonic/tonic/src/server/
H A Dservice.rs1 use crate::{Request, Response, Status, Streaming};
18 fn call(&mut self, request: Request<R>) -> Self::Future; in call()
23 T: Service<Request<M1>, Response = Response<M2>, Error = crate::Status>,
28 fn call(&mut self, request: Request<M1>) -> Self::Future { in call()
48 fn call(&mut self, request: Request<R>) -> Self::Future; in call()
53 T: Service<Request<M1>, Response = Response<S>, Error = crate::Status>,
60 fn call(&mut self, request: Request<M1>) -> Self::Future { in call()
77 fn call(&mut self, request: Request<Streaming<R>>) -> Self::Future; in call()
87 fn call(&mut self, request: Request<Streaming<M1>>) -> Self::Future { in call()
107 fn call(&mut self, request: Request<Streaming<R>>) -> Self::Future; in call()
[all …]
H A Dgrpc.rs10 Request, Status,
222 req: http::Request<B>, in unary()
265 req: http::Request<B>, in server_streaming()
306 req: http::Request<B>, in client_streaming()
339 req: http::Request<B>, in streaming()
366 request: http::Request<B>, in map_request_unary()
367 ) -> Result<Request<T::Decode>, Status> in map_request_unary()
399 request: http::Request<B>, in map_request_streaming()
400 ) -> Result<Request<Streaming<T::Decode>>, Status> in map_request_streaming()
416 Ok(Request::from_http(request)) in map_request_streaming()
[all …]
/tonic/examples/src/interceptor/
H A Dclient.rs7 Request, Status,
22 let request = tonic::Request::new(HelloRequest { in main()
36 fn intercept(req: Request<()>) -> Result<Request<()>, Status> { in intercept() argument
46 fn call(&mut self, request: tonic::Request<()>) -> Result<tonic::Request<()>, Status> { in call() argument
72 InterceptedService<Channel, fn(tonic::Request<()>) -> Result<tonic::Request<()>, Status>>, in using_function_pointer_interceptro()
H A Dserver.rs1 use tonic::{transport::Server, Request, Response, Status};
17 request: Request<HelloRequest>, in say_hello()
49 fn intercept(mut req: Request<()>) -> Result<Request<()>, Status> { in intercept() argument
/tonic/tonic/src/
H A Drequest.rs18 pub struct Request<T> { struct
55 fn into_request(self) -> Request<T>; in into_request()
101 impl<T> Request<T> { implementation
114 Request { in new()
161 Request { in from_http_parts()
180 ) -> http::Request<T> { in into_http()
202 Request { in map()
357 Request::new(self) in into_request()
361 impl<T> IntoRequest<T> for Request<T> { implementation
375 Request::new(self) in into_streaming_request()
[all …]
/tonic/tonic/src/service/
H A Dinterceptor.rs43 fn call(&mut self, request: crate::Request<()>) -> Result<crate::Request<()>, Status>; in call() argument
48 F: FnMut(crate::Request<()>) -> Result<crate::Request<()>, Status>,
50 fn call(&mut self, request: crate::Request<()>) -> Result<crate::Request<()>, Status> { in call() argument
129 fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future { in call()
138 let req = crate::Request::from_http(req); in call()
143 .call(crate::Request::from_parts(metadata, extensions, ())) in call()
300 let request = http::Request::builder() in doesnt_remove_headers_from_requests()
313 let svc = tower::service_fn(|_: http::Request<()>| async { in handles_intercepted_status_as_response()
317 let svc = InterceptedService::new(svc, |_: crate::Request<()>| { in handles_intercepted_status_as_response()
321 let request = http::Request::builder().body(()).unwrap(); in handles_intercepted_status_as_response()
[all …]
H A Drouter.rs2 use http::{Request, Response};
28 S: Service<Request<Body>, Error = Infallible> in add_service()
60 S: Service<Request<Body>, Error = Infallible> in new()
80 S: Service<Request<Body>, Error = Infallible> in add_service()
91 svc.map_request(|req: Request<axum::body::Body>| req.map(Body::new)), in add_service()
143 impl<B> Service<Request<B>> for Routes
157 fn call(&mut self, req: Request<B>) -> Self::Future { in call()
/tonic/tests/default_stubs/src/
H A Dlib.rs7 use tonic::{Request, Response, Status, Streaming};
21 async fn unary(&self, _: Request<()>) -> Result<Response<()>, Status> { in unary()
27 _: Request<()>, in server_stream() argument
32 async fn client_stream(&self, _: Request<Streaming<()>>) -> Result<Response<()>, Status> { in client_stream()
38 _: Request<Streaming<()>>, in bidirectional_stream()
/tonic/examples/src/tower/
H A Dclient.rs6 use tonic::{transport::Channel, Request, Status};
24 let request = tonic::Request::new(HelloRequest { in main()
36 fn intercept(req: Request<()>) -> Result<Request<()>, Status> { in intercept() argument
42 use http::{Request, Response};
60 impl Service<Request<Body>> for AuthSvc {
70 fn call(&mut self, req: Request<Body>) -> Self::Future { in call()
H A Dserver.rs5 use tonic::{transport::Server, Request, Response, Status};
22 request: Request<HelloRequest>, in say_hello()
61 fn intercept(req: Request<()>) -> Result<Request<()>, Status> { in intercept() argument
83 impl<S, ReqBody, ResBody> Service<http::Request<ReqBody>> for MyMiddleware<S>
85 S: Service<http::Request<ReqBody>, Response = http::Response<ResBody>> + Clone + Send + 'static,
97 fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future { in call()
/tonic/tests/deprecated_methods/proto/
H A Dtest.proto6 rpc Deprecated(Request) returns (Response) {
9 rpc NotDeprecated(Request) returns (Response);
12 message Request {} message
/tonic/tests/integration_tests/tests/
H A Dinterceptor.rs6 GrpcMethod, Request, Response, Status,
17 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in interceptor_retrieves_grpc_method()
43 fn client_intercept(req: Request<()>) -> Result<Request<()>, Status> { in interceptor_retrieves_grpc_method() argument
55 client.unary_call(Request::new(Input {})).await.unwrap(); in interceptor_retrieves_grpc_method()
H A Dconnection.rs7 Code, Request, Response, Status,
14 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
60 client.unary_call(Request::new(Input {})).await.unwrap(); in connect_returns_err_via_call_after_connected()
64 let res = client.unary_call(Request::new(Input {})).await; in connect_returns_err_via_call_after_connected()
83 client.unary_call(Request::new(Input {})).await.unwrap_err(); in connect_lazy_reconnects_after_first_failure()
106 client.unary_call(Request::new(Input {})).await.unwrap(); in connect_lazy_reconnects_after_first_failure()
110 let err = client.unary_call(Request::new(Input {})).await.unwrap_err(); in connect_lazy_reconnects_after_first_failure()
H A Dextensions.rs14 Request, Response, Status,
27 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_interceptor()
35 let svc = test_server::TestServer::with_interceptor(Svc, |mut req: Request<()>| { in setting_extension_from_interceptor()
77 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_tower()
125 impl<S> Service<http::Request<Body>> for InterceptedService<S>
127 S: Service<http::Request<Body>, Response = http::Response<Body>>
142 fn call(&mut self, mut req: http::Request<Body>) -> Self::Future { in call()
/tonic/tonic/src/transport/server/
H A Dmod.rs49 use http::{Request, Response};
403 S: Service<Request<Body>, Error = Infallible> in add_service()
427 S: Service<Request<Body>, Error = Infallible> in add_optional_service()
551 <<L as Layer<S>>::Service as Service<Request<Body>>>::Error: in serve()
837 S: Service<Request<Body>, Error = Infallible> in add_service()
857 S: Service<Request<Body>, Error = Infallible> in add_optional_service()
987 impl<S, ResBody> Service<Request<Body>> for Svc<S>
989 S: Service<Request<Body>, Response = Response<ResBody>>,
1002 fn call(&mut self, mut req: Request<Body>) -> Self::Future { in call()
1005 let bodyless_request = Request::from_parts(parts, ()); in call()
[all …]
/tonic/examples/src/authentication/
H A Dserver.rs6 use tonic::{metadata::MetadataValue, transport::Server, Request, Response, Status};
15 async fn unary_echo(&self, request: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo()
33 fn check_auth(req: Request<()>) -> Result<Request<()>, Status> { in check_auth() argument
H A Dclient.rs6 use tonic::{metadata::MetadataValue, transport::Channel, Request};
14 let mut client = EchoClient::with_interceptor(channel, move |mut req: Request<()>| { in main()
19 let request = tonic::Request::new(EchoRequest { in main()
/tonic/tonic/src/transport/channel/service/
H A Dadd_origin.rs4 use http::{Request, Uri};
29 impl<T, ReqBody> Service<Request<ReqBody>> for AddOrigin<T>
31 T: Service<Request<ReqBody>>,
43 fn call(&mut self, req: Request<ReqBody>) -> Self::Future { in call()
63 let request = Request::from_parts(head, body); in call()
H A Duser_agent.rs1 use http::{header::USER_AGENT, HeaderValue, Request};
29 impl<T, ReqBody> Service<Request<ReqBody>> for UserAgent<T>
31 T: Service<Request<ReqBody>>,
41 fn call(&mut self, mut req: Request<ReqBody>) -> Self::Future { in call()
/tonic/tests/compression/src/
H A Dlib.rs16 Request, Response, Status, Streaming,
49 async fn compress_output_unary(&self, _req: Request<()>) -> Result<Response<SomeData>, Status> { in compress_output_unary()
57 async fn compress_input_unary(&self, req: Request<SomeData>) -> Result<Response<()>, Status> { in compress_input_unary()
67 _req: Request<()>, in compress_output_server_stream() argument
78 req: Request<Streaming<SomeData>>, in compress_input_client_stream()
89 req: Request<Streaming<SomeData>>, in compress_output_client_stream()
108 req: Request<Streaming<SomeData>>, in compress_input_output_bidirectional_stream()
/tonic/interop/src/
H A Dserver.rs11 use tonic::{body::Body, server::NamedService, Code, Request, Response, Status};
21 type Streaming<T> = Request<tonic::Streaming<T>>;
27 async fn empty_call(&self, _request: Request<Empty>) -> Result<Empty> { in empty_call()
31 async fn unary_call(&self, request: Request<SimpleRequest>) -> Result<SimpleResponse> { in unary_call()
57 async fn cacheable_unary_call(&self, _: Request<SimpleRequest>) -> Result<SimpleResponse> { in cacheable_unary_call()
65 req: Request<StreamingOutputCallRequest>, in streaming_output_call()
153 async fn unimplemented_call(&self, _: Request<Empty>) -> Result<Empty> { in unimplemented_call()
163 async fn unimplemented_call(&self, _req: Request<Empty>) -> Result<Empty> { in unimplemented_call()
183 impl<S> Service<http::Request<Body>> for EchoHeadersSvc<S>
185 S: Service<http::Request<Body>, Response = http::Response<Body>> + Send,
[all …]
H A Dclient.rs8 use tonic::{metadata::MetadataValue, Code, Request, Response, Status};
22 let result = client.empty_call(Request::new(Empty {})).await; in empty_unary()
50 let result = client.unary_call(Request::new(req)).await; in large_unary()
92 let result = client.streaming_input_call(Request::new(stream)).await; in client_streaming()
119 let req = Request::new(req); in server_streaming()
158 .full_duplex_call(Request::new( in ping_pong()
211 let result = client.full_duplex_call(Request::new(stream)).await; in empty_stream()
270 let result = client.unary_call(Request::new(simple_req)).await; in status_code_and_message()
295 let result = client.unary_call(Request::new(req)).await; in special_status_message()
355 let mut req_unary = Request::new(req); in custom_metadata()
[all …]
/tonic/tonic-web/src/
H A Dservice.rs46 impl<S, B> Service<Request<B>> for GrpcWebService<S>
206 fn coerce_request<B>(mut req: Request<B>, encoding: Encoding) -> Request<Body> in coerce_request()
291 fn request() -> Request<Body> { in request()
292 Request::builder() in request()
372 fn request() -> Request<Body> { in request()
373 Request::builder() in request()
394 fn request() -> Request<Body> { in request()
395 Request::builder() in request()
416 let req = Request::builder() in h1_is_err()
446 fn request() -> Request<Body> { in request()
[all …]
/tonic/examples/src/h2c/
H A Dserver.rs7 use tonic::{service::Routes, Request, Response, Status};
23 request: Request<HelloRequest>, in say_hello()
69 use http::{Request, Response};
82 impl<S> Service<Request<Incoming>> for H2c<S>
84 S: Service<Request<Body>, Response = Response<Body>> + Clone + Send + 'static,
100 fn call(&mut self, req: hyper::Request<Incoming>) -> Self::Future { in call()
105 .map_request(|req: Request<_>| req.map(Body::new)); in call()
/tonic/tonic/src/client/
H A Dservice.rs29 fn call(&mut self, request: http::Request<ReqBody>) -> Self::Future; in call()
34 T: Service<http::Request<ReqBody>, Response = http::Response<ResBody>>,
47 fn call(&mut self, request: http::Request<ReqBody>) -> Self::Future { in call()

12345