Home
last modified time | relevance | path

Searched refs:Response (Results 1 – 25 of 95) sorted by relevance

1234

/tonic/tonic/src/server/
H A Dservice.rs12 type Response; typedef
15 type Future: Future<Output = Result<Response<Self::Response>, Status>>;
23 T: Service<Request<M1>, Response = Response<M2>, Error = crate::Status>,
25 type Response = M2; typedef
39 type Response; typedef
53 T: Service<Request<M1>, Response = Response<S>, Error = crate::Status>,
56 type Response = M2; typedef
71 type Response; typedef
74 type Future: Future<Output = Result<Response<Self::Response>, Status>>;
84 type Response = M2; typedef
[all …]
/tonic/tonic/src/
H A Dresponse.rs7 pub struct Response<T> { struct
13 impl<T> Response<T> { impl
27 Response { in new()
75 Response { in from_http()
82 pub(crate) fn into_http(self) -> http::Response<T> { in into_http()
83 let mut res = http::Response::new(self.message); in into_http()
93 pub fn map<F, U>(self, f: F) -> Response<U> in map()
98 Response { in map()
130 impl<T> From<T> for Response<T> { implementation
132 Response::new(inner) in from()
[all …]
/tonic/tests/compression/src/
H A Dlib.rs16 Request, Response, Status, Streaming,
38 fn prepare_response<B>(&self, mut res: Response<B>) -> Response<B> { in prepare_response()
52 Ok(self.prepare_response(Response::new(SomeData { in compress_output_unary()
59 Ok(Response::new(())) in compress_input_unary()
68 ) -> Result<Response<Self::CompressOutputServerStreamStream>, Status> { in compress_output_server_stream()
73 Ok(self.prepare_response(Response::new(Box::pin(stream)))) in compress_output_server_stream()
79 ) -> Result<Response<()>, Status> { in compress_input_client_stream() argument
84 Ok(self.prepare_response(Response::new(()))) in compress_input_client_stream()
90 ) -> Result<Response<SomeData>, Status> { in compress_output_client_stream()
98 Ok(self.prepare_response(Response::new(SomeData { in compress_output_client_stream()
[all …]
/tonic/tests/integration_tests/tests/
H A Dcomplex_tower_middleware.rs10 use tonic::{transport::Server, Request, Response, Status};
19 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in complex_tower_layers_work()
58 S: Service<R, Response = http::Response<ResBody>>,
60 type Response = http::Response<MyBody<ResBody>>; typedef
80 F: Future<Output = Result<http::Response<B>, E>>,
82 type Output = Result<http::Response<MyBody<B>>, BoxError>;
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()
31 Ok(Response::new(Output {})) in setting_extension_from_interceptor()
77 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_tower()
81 Ok(Response::new(Output {})) in setting_extension_from_tower()
127 S: Service<http::Request<Body>, Response = http::Response<Body>>
134 type Response = S::Response; typedef
136 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
H A Droutes_builder.rs14 Request, Response, Status,
23 async fn unary_call(&self, _req: Request<Input>) -> Result<Response<Output>, Status> { in multiple_service_using_routes_builder()
24 Ok(Response::new(Output {})) in multiple_service_using_routes_builder()
32 async fn unary_call(&self, request: Request<Input1>) -> Result<Response<Output1>, Status> { in multiple_service_using_routes_builder()
33 Ok(Response::new(Output1 { in multiple_service_using_routes_builder()
43 ) -> Result<Response<Self::StreamCallStream>, Status> { in multiple_service_using_routes_builder()
49 Ok(Response::new(Box::pin(stream))) in multiple_service_using_routes_builder()
H A Dorigin.rs11 Response, Status,
25 ) -> Result<Response<Output>, Status> { in writes_origin_header()
26 Ok(Response::new(Output {})) in writes_origin_header()
90 type Response = T::Response; typedef
92 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
/tonic/tests/web/src/
H A Dlib.rs4 use tonic::{Request, Response, Status, Streaming};
18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
24 Ok(Response::new(Output { in unary_call()
36 ) -> Result<Response<Self::ServerStreamStream>, Status> { in server_stream()
39 Ok(Response::new(Box::pin(stream::iter(vec![1, 2]).map( in server_stream()
52 ) -> Result<Response<Output>, Status> { in client_stream()
58 Ok(Response::new( in client_stream()
/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() argument
28 ) -> Result<Response<Self::ServerStreamStream>, Status> { in server_stream()
32 async fn client_stream(&self, _: Request<Streaming<()>>) -> Result<Response<()>, Status> { in client_stream() argument
39 ) -> Result<Response<Self::BidirectionalStreamStream>, Status> { in bidirectional_stream()
/tonic/examples/src/h2c/
H A Dserver.rs7 use tonic::{service::Routes, Request, Response, Status};
24 ) -> Result<Response<HelloReply>, Status> { in say_hello()
30 Ok(Response::new(reply)) in say_hello()
69 use http::{Request, Response};
84 S: Service<Request<Body>, Response = Response<Body>> + Clone + Send + 'static,
88 type Response = hyper::Response<Body>; typedef
91 Pin<Box<dyn std::future::Future<Output = Result<Self::Response, Self::Error>> + Send>>;
116 let mut res = hyper::Response::new(Body::default()); in call()
/tonic/examples/src/tower/
H A Dserver.rs5 use tonic::{transport::Server, Request, Response, Status};
23 ) -> Result<Response<HelloReply>, Status> { in say_hello()
29 Ok(Response::new(reply)) in say_hello()
85 S: Service<http::Request<ReqBody>, Response = http::Response<ResBody>> + Clone + Send + 'static,
89 type Response = S::Response; typedef
91 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
/tonic/tests/deprecated_methods/proto/
H A Dtest.proto6 rpc Deprecated(Request) returns (Response) {
9 rpc NotDeprecated(Request) returns (Response);
14 message Response {} message
/tonic/examples/src/multiplex/
H A Dserver.rs1 use tonic::{transport::Server, Request, Response, Status};
45 ) -> Result<Response<HelloReply>, Status> { in say_hello()
49 Ok(Response::new(reply)) in say_hello()
61 ) -> Result<Response<EchoResponse>, Status> { in unary_echo()
63 Ok(Response::new(EchoResponse { message })) in unary_echo()
/tonic/examples/src/cancellation/
H A Dserver.rs4 use tonic::{transport::Server, Request, Response, Status};
25 ) -> Result<Response<HelloReply>, Status> { in say_hello()
37 Ok(Response::new(reply)) in say_hello()
52 ) -> Result<Response<HelloReply>, Status> in with_cancellation_handler()
54 FRequest: Future<Output = Result<Response<HelloReply>, Status>> + Send + 'static, in with_cancellation_handler()
55 FCancellation: Future<Output = Result<Response<HelloReply>, Status>> + Send + 'static, in with_cancellation_handler()
/tonic/tonic/src/service/
H A Drouter.rs2 use http::{Request, Response};
34 S::Response: axum::response::IntoResponse, in add_service()
66 S::Response: axum::response::IntoResponse, in new()
86 S::Response: axum::response::IntoResponse, in add_service()
138 async fn unimplemented() -> Response<Body> { in unimplemented()
140 Response::from_parts(parts, Body::empty()) in unimplemented()
148 type Response = Response<Body>; typedef
171 type Output = Result<Response<Body>, crate::BoxError>;
H A Drecover_error.rs10 use http::Response;
54 S: Service<Req, Response = Response<ResBody>>,
57 type Response = Response<ResponseBody<ResBody>>; typedef
87 F: Future<Output = Result<Response<ResBody>, E>>,
90 type Output = Result<Response<ResponseBody<ResBody>>, crate::BoxError>;
101 let res = Response::from_parts(parts, ResponseBody::empty()); in poll()
/tonic/tonic-web/src/
H A Dclient.rs2 use http::{Request, Response, Version};
53 S: Service<Request<GrpcWebCall<B1>>, Response = Response<B2>>,
55 type Response = Response<GrpcWebCall<B2>>; typedef
91 F: Future<Output = Result<Response<B>, E>>,
93 type Output = Result<Response<GrpcWebCall<B>>, E>;
/tonic/tonic/src/transport/channel/service/
H A Dconnection.rs6 use http::{Request, Response, Uri};
24 inner: BoxService<Request<Body>, Response<Body>, crate::BoxError>,
33 C::Response: rt::Read + rt::Write + Unpin + Send + 'static, in new()
88 C::Response: rt::Read + rt::Write + Unpin + Send + 'static, in connect()
98 C::Response: rt::Read + rt::Write + Unpin + Send + 'static, in lazy()
105 type Response = Response<Body>; typedef
107 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
143 type Response = Response<Body>; typedef
145 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
179 C::Response: rt::Read + rt::Write + Unpin + Send,
[all …]
/tonic/interop/src/
H A Dserver.rs11 use tonic::{body::Body, server::NamedService, Code, Request, Response, Status};
20 type Result<T> = StdResult<Response<T>, Status>;
28 Ok(Response::new(Empty {})) in empty_call()
54 Ok(Response::new(res)) in unary_call()
81 Ok(Response::new( in streaming_output_call()
101 Ok(Response::new(res)) in streaming_input_call()
137 Ok(Response::new(Box::pin(stream) as Self::FullDuplexCallStream)) in full_duplex_call()
140 Ok(Response::new(Box::pin(stream) as Self::FullDuplexCallStream)) in full_duplex_call()
185 S: Service<http::Request<Body>, Response = http::Response<Body>> + Send,
188 type Response = S::Response; typedef
[all …]
/tonic/tests/use_arc_self/src/
H A Dlib.rs5 use tonic::{Request, Response, Status};
17 ) -> Result<Response<SomeData>, Status> { in test_request()
18 Ok(Response::new(req.into_inner())) in test_request()
/tonic/tonic/benches-disabled/benchmarks/compiled_protos/
H A Dhelloworld.rs57 ) -> Result<tonic::Response<super::HelloReply>, tonic::Status> { in say_hello()
83 ) -> Result<tonic::Response<super::HelloReply>, tonic::Status> { in say_hello()
113 type Response = GreeterServerSvc<T>; typedef
115 type Future = Ready<Result<Self::Response, Self::Error>>;
124 type Response = http::Response<tonic::body::BoxBody>; typedef
126 type Future = BoxFuture<Self::Response, Self::Error>;
136 type Response = super::HelloReply; in call() typedef
137 type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; in call()
158 Ok(http::Response::builder() in call()
/tonic/examples/src/routeguide/
H A Dserver.rs9 use tonic::{Request, Response, Status};
27 async fn get_feature(&self, request: Request<Point>) -> Result<Response<Feature>, Status> { in get_feature()
32 return Ok(Response::new(feature.clone())); in get_feature()
36 Ok(Response::new(Feature::default())) in get_feature()
44 ) -> Result<Response<Self::ListFeaturesStream>, Status> { in list_features()
61 Ok(Response::new(ReceiverStream::new(rx))) in list_features()
67 ) -> Result<Response<RouteSummary>, Status> { in record_route()
101 Ok(Response::new(summary)) in record_route()
109 ) -> Result<Response<Self::RouteChatStream>, Status> { in route_chat()
130 Ok(Response::new(Box::pin(output) as Self::RouteChatStream)) in route_chat()
/tonic/examples/src/dynamic/
H A Dserver.rs2 use tonic::{service::RoutesBuilder, transport::Server, Request, Response, Status};
18 type EchoResult<T> = Result<Response<T>, Status>;
30 Ok(Response::new(EchoResponse { message })) in unary_echo()
51 ) -> Result<Response<HelloReply>, Status> { in say_hello()
57 Ok(Response::new(reply)) in say_hello()
/tonic/tonic-health/src/generated/
H A Dgrpc_health_v1.rs97 Response = http::Response< in with_interceptor() argument
144 tonic::Response<super::HealthCheckResponse>, in check()
183 tonic::Response<tonic::codec::Streaming<super::HealthCheckResponse>>, in watch()
224 tonic::Response<super::HealthCheckResponse>, in check()
318 type Response = http::Response<tonic::body::Body>; typedef
320 type Future = BoxFuture<Self::Response, Self::Error>;
336 type Response = super::HealthCheckResponse; in call() typedef
338 tonic::Response<Self::Response>, in call()
381 type Response = super::HealthCheckResponse; in call() typedef
384 tonic::Response<Self::ResponseStream>, in call()
[all …]
/tonic/tonic/src/transport/server/
H A Dmod.rs49 use http::{Request, Response};
549 L::Service: Service<Request<Body>, Response = Response<ResBody>> + Clone + Send + 'static, in serve() argument
569 L::Service: Service<Request<Body>, Response = Response<ResBody>> + Clone + Send + 'static, in serve_with_shutdown() argument
590 L::Service: Service<Request<Body>, Response = Response<ResBody>> + Clone + Send + 'static, in serve_with_incoming() argument
613 L::Service: Service<Request<Body>, Response = Response<ResBody>> + Clone + Send + 'static, in serve_with_incoming_shutdown() argument
635 L::Service: Service<Request<Body>, Response = Response<ResBody>> + Clone + Send + 'static, in serve_internal() argument
778 S: HyperService<Request<Incoming>, Response = Response<B>> + Clone + Send + 'static, in serve_connection() argument
989 S: Service<Request<Body>, Response = Response<ResBody>>,
994 type Response = Response<Body>; typedef
1068 S: Service<Request<Body>, Response = Response<ResBody>> + Clone + Send + 'static,
[all …]

1234