Home
last modified time | relevance | path

Searched refs:Future (Results 1 – 25 of 39) sorted by relevance

12

/tonic/tonic/src/server/
H A Dservice.rs2 use std::future::Future;
15 type Future: Future<Output = Result<Response<Self::Response>, Status>>; typedef
18 fn call(&mut self, request: Request<R>) -> Self::Future; in call() argument
26 type Future = T::Future; typedef
45 type Future: Future<Output = Result<Response<Self::ResponseStream>, Status>>; typedef
48 fn call(&mut self, request: Request<R>) -> Self::Future; in call() argument
58 type Future = T::Future; typedef
74 type Future: Future<Output = Result<Response<Self::Response>, Status>>; typedef
85 type Future = T::Future; typedef
104 type Future: Future<Output = Result<Response<Self::ResponseStream>, Status>>; typedef
[all …]
/tonic/tonic/src/client/
H A Dservice.rs2 use std::future::Future;
19 type Future: Future<Output = Result<http::Response<Self::ResponseBody>, Self::Error>>; typedef
29 fn call(&mut self, request: http::Request<ReqBody>) -> Self::Future; in call() argument
41 type Future = T::Future; typedef
47 fn call(&mut self, request: http::Request<ReqBody>) -> Self::Future { in call() argument
/tonic/tonic/src/transport/channel/service/
H A Dreconnect.rs4 future::Future,
18 state: State<M::Future, M::Response>,
53 M::Future: Unpin,
60 type Future = ResponseFuture<S::Future>; typedef
140 fn call(&mut self, request: Request) -> Self::Future { in call() argument
159 M::Future: fmt::Debug,
184 Future(#[pin] F), enumerator
191 inner: Inner::Future(inner), in new()
202 impl<F, T, E> Future for ResponseFuture<F>
204 F: Future<Output = Result<T, E>>,
[all …]
H A Dconnection.rs32 C::Future: Send, in new()
87 C::Future: Unpin + Send, in connect()
97 C::Future: Send, in lazy()
107 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>; typedef
113 fn call(&mut self, req: Request<Body>) -> Self::Future { in call() argument
145 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>; typedef
151 fn call(&mut self, req: Request<Body>) -> Self::Future { in call() argument
178 C::Future: Send,
183 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>; typedef
189 fn call(&mut self, req: Uri) -> Self::Future { in call() argument
H A Duser_agent.rs35 type Future = T::Future; typedef
41 fn call(&mut self, mut req: Request<ReqBody>) -> Self::Future { in call() argument
H A Dexecutor.rs3 use std::{future::Future, sync::Arc};
29 F: Future<Output = ()> + Send + 'static,
H A Dadd_origin.rs32 T::Future: Send + 'static,
37 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>; typedef
43 fn call(&mut self, req: Request<ReqBody>) -> Self::Future { in call() argument
H A Dconnector.rs37 C::Future: Send + 'static,
42 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>; typedef
50 fn call(&mut self, uri: Uri) -> Self::Future { in call() argument
/tonic/tests/integration_tests/tests/
H A Dcomplex_tower_middleware.rs6 future::Future,
62 type Future = MyFuture<S::Future, ResBody>; typedef
68 fn call(&mut self, req: R) -> Self::Future { in call() argument
78 impl<F, E, B> Future for MyFuture<F, B>
80 F: Future<Output = Result<http::Response<B>, E>>,
/tonic/tonic-web/src/
H A Dclient.rs5 use std::future::Future;
57 type Future = ResponseFuture<S::Future>; typedef
63 fn call(&mut self, mut req: Request<B1>) -> Self::Future { in call() argument
89 impl<F, B, E> Future for ResponseFuture<F>
91 F: Future<Output = Result<Response<B>, E>>,
H A Dservice.rs2 use std::future::Future;
54 type Future = ResponseFuture<S::Future>; typedef
60 fn call(&mut self, req: Request<B>) -> Self::Future { in call() argument
155 impl<F, E> Future for ResponseFuture<F>
157 F: Future<Output = Result<Response<Body>, E>>,
253 type BoxFuture<T, E> = Pin<Box<dyn Future<Output = Result<T, E>> + Send>>;
261 type Future = BoxFuture<Self::Response, Self::Error>; typedef
267 fn call(&mut self, _: Request<Body>) -> Self::Future { in call() argument
/tonic/tonic/src/service/
H A Drouter.rs6 future::Future,
35 S::Future: Send + 'static, in add_service()
67 S::Future: Send + 'static, in new()
87 S::Future: Send + 'static, in add_service()
150 type Future = RoutesFuture; typedef
157 fn call(&mut self, req: Request<B>) -> Self::Future { in call() argument
170 impl Future for RoutesFuture {
H A Drecover_error.rs5 future::Future,
59 type Future = ResponseFuture<S::Future>; typedef
65 fn call(&mut self, req: Req) -> Self::Future { in call() argument
85 impl<F, E, ResBody> Future for ResponseFuture<F>
87 F: Future<Output = Result<Response<ResBody>, E>>,
H A Dinterceptor.rs9 future::Future,
122 type Future = ResponseFuture<S::Future>; typedef
129 fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future { in call() argument
175 kind: Kind::Future(future), in future()
189 Future(#[pin] F), enumerator
193 impl<F, E, B> Future for ResponseFuture<F>
195 F: Future<Output = Result<http::Response<B>, E>>,
201 KindProj::Future(future) => future.poll(cx).map_ok(|res| res.map(ResponseBody::wrap)), in poll()
H A Dlayered.rs28 type Future = S::Future; typedef
34 fn call(&mut self, req: Req) -> Self::Future { in call() argument
/tonic/examples/src/tower/
H A Dclient.rs43 use std::future::Future;
64 type Future = Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send>>; typedef
70 fn call(&mut self, req: Request<Body>) -> Self::Future { in call() argument
H A Dserver.rs81 type BoxFuture<'a, T> = Pin<Box<dyn std::future::Future<Output = T> + Send + 'a>>;
86 S::Future: Send + 'static,
91 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>; typedef
97 fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future { in call() argument
/tonic/tonic/src/transport/server/
H A Dmod.rs56 future::{self, poll_fn, Future},
410 S::Future: Send + 'static, in add_service()
573 F: Future<Output = ()>, in serve_with_shutdown()
620 F: Future<Output = ()>, in serve_with_incoming_shutdown()
642 F: Future<Output = ()>, in serve_internal()
779 S::Future: Send + 'static, in serve_connection()
960 F: Future<Output = ()>, in serve_with_incoming_shutdown()
996 type Future = SvcFuture<S::Future>; typedef
1069 S::Future: Send,
1117 impl<F> Future for Fuse<F>
[all …]
/tonic/tonic/src/transport/channel/
H A Dmod.rs22 future::Future,
38 type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>;
140 E: Executor<Pin<Box<dyn Future<Output = ()> + Send>>> + Send + Sync + 'static, in balance_channel_with_executor()
154 C::Future: Send, in new()
175 C::Future: Unpin + Send, in connect()
210 type Future = ResponseFuture; typedef
216 fn call(&mut self, request: http::Request<Body>) -> Self::Future { in call() argument
223 impl Future for ResponseFuture {
/tonic/tonic/src/
H A Dcodegen.rs6 pub use std::future::Future;
19 pub type BoxFuture<T, E> = self::Pin<Box<dyn self::Future<Output = Result<T, E>> + Send + 'static>>;
/tonic/examples/src/cancellation/
H A Dserver.rs1 use std::future::Future;
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/benches-disabled/benchmarks/compiled_protos/
H A Dhelloworld.rs115 type Future = Ready<Result<Self::Response, Self::Error>>; typedef
119 fn call(&mut self, _: R) -> Self::Future { in call() argument
126 type Future = BoxFuture<Self::Response, Self::Error>; typedef
130 fn call(&mut self, req: http::Request<HyperBody>) -> Self::Future { in call() argument
137 type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; in call() typedef
141 ) -> Self::Future { in call() argument
/tonic/tonic/src/transport/service/
H A Dgrpc_timeout.rs5 future::Future,
35 type Future = ResponseFuture<S::Future>; typedef
41 fn call(&mut self, req: Request<ReqBody>) -> Self::Future { in call() argument
73 impl<F, Res, E> Future for ResponseFuture<F>
75 F: Future<Output = Result<Res, E>>,
/tonic/examples/src/h2c/
H A Dclient.rs52 type Future = typedef
53 Pin<Box<dyn std::future::Future<Output = Result<Self::Response, Self::Error>> + Send>>;
59 fn call(&mut self, request: http::Request<Body>) -> Self::Future { in call() argument
H A Dserver.rs85 S::Future: Send,
90 type Future = typedef
91 Pin<Box<dyn std::future::Future<Output = Result<Self::Response, Self::Error>> + Send>>;
100 fn call(&mut self, req: hyper::Request<Incoming>) -> Self::Future { in call() argument

12