| /tonic/tonic/src/service/ |
| H A D | interceptor.rs | 9 future::Future,
149 ResponseFuture::future(self.inner.call(req)) in call()
173 fn future(future: F) -> Self { in future() method
175 kind: Kind::Future(future), in future()
201 KindProj::Future(future) => future.poll(cx).map_ok(|res| res.map(ResponseBody::wrap)), in poll()
|
| H A D | router.rs | 6 future::Future,
162 pub struct RoutesFuture(axum::routing::future::RouteFuture<Infallible>);
|
| H A D | recover_error.rs | 5 future::Future,
|
| /tonic/tonic-web/src/ |
| H A D | service.rs | 2 use std::future::Future;
80 future: self.inner.call(coerce_request(req, encoding)), in call()
103 future: self.inner.call(req.map(Body::new)), in call()
132 future: F,
137 future: F,
165 CaseProj::GrpcWeb { future, accept } => { in poll()
166 let res = ready!(future.poll(cx))?; in poll()
170 CaseProj::Other { future } => future.poll(cx), in poll()
|
| H A D | client.rs | 5 use std::future::Future;
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | executor.rs | 3 use std::{future::Future, sync::Arc};
|
| H A D | reconnect.rs | 4 future::Future,
|
| /tonic/tonic/src/ |
| H A D | codegen.rs | 6 pub use std::future::Future;
|
| /tonic/tonic/src/client/ |
| H A D | service.rs | 2 use std::future::Future;
|
| H A D | grpc.rs | 16 use std::{fmt, future, pin::pin};
203 future::poll_fn(|cx| self.inner.poll_ready(cx)).await in ready()
|
| /tonic/tests/integration_tests/src/ |
| H A D | lib.rs | 74 pub type BoxFuture<'a, T> = std::pin::Pin<Box<dyn std::future::Future<Output = T> + Send + 'a>>;
|
| /tonic/examples/src/cancellation/ |
| H A D | server.rs | 1 use std::future::Future;
|
| /tonic/examples/src/tower/ |
| H A D | client.rs | 43 use std::future::Future;
|
| H A D | server.rs | 81 type BoxFuture<'a, T> = Pin<Box<dyn std::future::Future<Output = T> + Send + 'a>>;
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 22 future::Future,
32 buffer::{future::ResponseFuture as BufferResponseFuture, Buffer},
|
| /tonic/tests/integration_tests/tests/ |
| H A D | complex_tower_middleware.rs | 6 future::Future,
|
| /tonic/examples/src/h2c/ |
| H A D | client.rs | 53 Pin<Box<dyn std::future::Future<Output = Result<Self::Response, Self::Error>> + Send>>;
|
| H A D | server.rs | 91 Pin<Box<dyn std::future::Future<Output = Result<Self::Response, Self::Error>> + Send>>;
|
| /tonic/tonic/src/server/ |
| H A D | service.rs | 2 use std::future::Future;
|
| /tonic/tonic/src/codec/ |
| H A D | decode.rs | 9 fmt, future,
330 match future::poll_fn(|cx| Pin::new(&mut *self).poll_next(cx)).await { in message()
|
| /tonic/tonic-health/proto/ |
| H A D | health.proto | 55 // future point, the serving status of the service becomes known, the
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 53 use std::future::pending;
56 future::{self, poll_fn, Future},
600 self.serve_internal(svc, incoming, Option::<future::Ready<()>>::None) in serve_with_incoming()
1076 type Future = future::Ready<Result<Self::Response, Self::Error>>;
1104 future::ready(Ok(svc)) in call()
|
| H A D | io_stream.rs | 2 use std::future::Future;
|
| /tonic/tonic/src/transport/service/ |
| H A D | grpc_timeout.rs | 5 future::Future,
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 1 use std::future::Future;
|