| /aosp_15_r20/external/rust/android-crates-io/crates/tonic/src/server/ |
| D | service.rs | 15 type Future: Future<Output = Result<Response<Self::Response>, Status>>; typedef
18 fn call(&mut self, request: Request<R>) -> Self::Future; in call()
26 type Future = T::Future; typedef
28 fn call(&mut self, request: Request<M1>) -> Self::Future { in call()
45 type Future: Future<Output = Result<Response<Self::ResponseStream>, Status>>; typedef
48 fn call(&mut self, request: Request<R>) -> Self::Future; in call()
58 type Future = T::Future; typedef
60 fn call(&mut self, request: Request<M1>) -> Self::Future { in call()
74 type Future: Future<Output = Result<Response<Self::Response>, Status>>; typedef
77 fn call(&mut self, request: Request<Streaming<R>>) -> Self::Future; in call()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/net/ |
| D | addr.rs | 41 type Future = T::Future; typedef
43 fn to_socket_addrs(&self, _: sealed::Internal) -> Self::Future { in to_socket_addrs()
54 type Future = ReadyFuture<Self::Iter>; typedef
56 fn to_socket_addrs(&self, _: sealed::Internal) -> Self::Future { in to_socket_addrs()
68 type Future = ReadyFuture<Self::Iter>; typedef
70 fn to_socket_addrs(&self, _: sealed::Internal) -> Self::Future { in to_socket_addrs()
81 type Future = ReadyFuture<Self::Iter>; typedef
83 fn to_socket_addrs(&self, _: sealed::Internal) -> Self::Future { in to_socket_addrs()
94 type Future = ReadyFuture<Self::Iter>; typedef
96 fn to_socket_addrs(&self, _: sealed::Internal) -> Self::Future { in to_socket_addrs()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures-util/src/future/ |
| D | join.rs | 46 impl<$($Fut: Future),*> Future for $Join<$($Fut),*> { impl
113 Fut1: Future, in join()
114 Fut2: Future, in join()
142 Fut1: Future, in join3()
143 Fut2: Future, in join3()
144 Fut3: Future, in join3()
174 Fut1: Future, in join4()
175 Fut2: Future, in join4()
176 Fut3: Future, in join4()
177 Fut4: Future, in join4()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/service/ |
| D | make.rs | 16 type Future: Future<Output = Result<Self::Connection, Self::Error>>; typedef
19 fn make_connection(&mut self, target: Target) -> Self::Future; in make_connection()
31 type Future = S::Future; typedef
37 fn make_connection(&mut self, target: Target) -> Self::Future { in make_connection()
49 type Future: Future<Output = Result<Self::Service, Self::MakeError>>; typedef
64 fn make_service_ref(&mut self, target: &Target) -> Self::Future; in make_service_ref()
81 type Future = F; typedef
89 fn make_service_ref(&mut self, target: &Target) -> Self::Future { in make_service_ref()
142 Ret: Future, in make_service_fn()
161 type Future = Ret; typedef
[all …]
|
| D | http.rs | 21 type Future: Future<Output = Result<Response<Self::ResBody>, Self::Error>>; typedef
27 fn call(&mut self, req: Request<ReqBody>) -> Self::Future; in call()
39 type Future = T::Future; typedef
45 fn call(&mut self, req: Request<B1>) -> Self::Future { in call()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/tests/retry/ |
| D | main.rs | 104 type Future = future::Ready<Self>; typedef
105 fn retry(&self, _: &Req, result: Result<&Res, &Error>) -> Option<Self::Future> { in retry()
122 type Future = future::Ready<Self>; typedef
123 fn retry(&self, _: &Req, result: Result<&Res, &Error>) -> Option<Self::Future> { in retry()
140 type Future = future::Ready<Self>; typedef
141 fn retry(&self, _: &Req, result: Result<&Res, &Error>) -> Option<Self::Future> { in retry()
160 type Future = future::Ready<Self>; typedef
161 fn retry(&self, _: &Req, _: Result<&Res, &Error>) -> Option<Self::Future> { in retry()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/src/make/ |
| D | make_service.rs | 35 type Future: Future<Output = Result<Self::Service, Self::MakeError>>; typedef
48 fn make_service(&mut self, target: Target) -> Self::Future; in make_service()
148 type Future = M::Future; typedef
154 fn make_service(&mut self, target: Target) -> Self::Future { in make_service()
199 type Future = M::Future; typedef
207 fn call(&mut self, target: Target) -> Self::Future { in call()
240 type Future = M::Future; typedef
248 fn call(&mut self, target: Target) -> Self::Future { in call()
|
| D | make_connection.rs | 20 type Future: Future<Output = Result<Self::Connection, Self::Error>>; typedef
26 fn make_connection(&mut self, target: Target) -> Self::Future; in make_connection()
38 type Future = C::Future; typedef
44 fn make_connection(&mut self, target: Target) -> Self::Future { in make_connection()
|
| /aosp_15_r20/external/crosvm/cros_async/src/ |
| H A D | lib.rs | 601 F1: Future, in complete2()
602 F2: Future, in complete2()
622 F1: Future, in complete3()
623 F2: Future, in complete3()
624 F3: Future, in complete3()
650 F1: Future, in complete4()
651 F2: Future, in complete4()
652 F3: Future, in complete4()
653 F4: Future, in complete4()
682 F1: Future, in complete5()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower-service/src/ |
| D | lib.rs | 319 type Future: Future<Output = Result<Self::Response, Self::Error>>; typedef
354 fn call(&mut self, req: Request) -> Self::Future; in call()
363 type Future = S::Future; typedef
369 fn call(&mut self, request: Request) -> S::Future { in call()
380 type Future = S::Future; typedef
386 fn call(&mut self, request: Request) -> S::Future { in call()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/axum/src/handler/ |
| D | mod.rs | 139 type Future: Future<Output = Response> + Send + 'static; typedef
142 fn call(self, req: Request<B>, state: S) -> Self::Future; in call()
205 type Future = Pin<Box<dyn Future<Output = Response> + Send>>; typedef
207 fn call(self, _req: Request<B>, _state: S) -> Self::Future { in call()
270 type Future = std::future::Ready<Response>; typedef
272 fn call(self, _req: Request<B>, _state: S) -> Self::Future { in call()
323 type Future = future::LayeredFuture<B2, L::Service>; typedef
325 fn call(self, req: Request<B2>, state: S) -> Self::Future { in call()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/task/ |
| D | raw.rs | 47 pub(super) fn vtable<T: Future, S: Schedule>() -> &'static Vtable { in vtable()
160 pub(super) fn new<T, S>(task: T, scheduler: S, id: Id) -> RawTask in new()
269 unsafe fn poll<T: Future, S: Schedule>(ptr: NonNull<Header>) { in poll()
283 unsafe fn dealloc<T: Future, S: Schedule>(ptr: NonNull<Header>) { in dealloc()
288 unsafe fn try_read_output<T: Future, S: Schedule>( in try_read_output()
299 unsafe fn drop_join_handle_slow<T: Future, S: Schedule>(ptr: NonNull<Header>) { in drop_join_handle_slow()
304 unsafe fn drop_abort_handle<T: Future, S: Schedule>(ptr: NonNull<Header>) { in drop_abort_handle()
309 unsafe fn shutdown<T: Future, S: Schedule>(ptr: NonNull<Header>) { in shutdown()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/server/ |
| D | server.rs | 160 E: NewSvcExec<IO, S::Future, S::Service, E, GracefulWatcher>, in with_graceful_shutdown()
168 ) -> Poll<Option<crate::Result<Connecting<IO, S::Future, E>>>> { in poll_next_()
197 E: NewSvcExec<IO, S::Future, S::Service, E, W>, in poll_watch()
571 E: NewSvcExec<I::Conn, S::Future, S::Service, E, NoopWatcher>, in serve()
572 E: ConnStreamExec<<S::Service as HttpService<Body>>::Future, B>, in serve()
653 type Future: Future<Output = crate::Result<()>>; typedef
655 fn watch(&self, conn: UpgradeableConnection<I, S, E>) -> Self::Future; in watch()
670 type Future = UpgradeableConnection<I, S, E>; typedef
672 fn watch(&self, conn: UpgradeableConnection<I, S, E>) -> Self::Future { in watch()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tonic/benches-disabled/benchmarks/compiled_protos/ |
| D | helloworld.rs | 115 type Future = Ready<Result<Self::Response, Self::Error>>; typedef
119 fn call(&mut self, _: R) -> Self::Future { in call()
126 type Future = BoxFuture<Self::Response, Self::Error>; typedef
130 fn call(&mut self, req: http::Request<HyperBody>) -> Self::Future { in call()
137 type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; in call() typedef
141 ) -> Self::Future { in call()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/src/util/ |
| D | future_service.rs | 124 Future(F), enumerator
150 type Future = S::Future; typedef
165 fn call(&mut self, req: R) -> Self::Future { in call()
205 type Future = Ready<Result<Self::Response, Self::Error>>; typedef
211 fn call(&mut self, _req: ()) -> Self::Future { in call()
|
| D | boxed_clone.rs | 92 type Future = BoxFuture<'static, Result<U, E>>; typedef
100 fn call(&mut self, request: T) -> Self::Future { in call()
115 dyn CloneService<R, Response = Self::Response, Error = Self::Error, Future = Self::Future> in clone_box() argument
126 … ) -> Box<dyn CloneService<R, Response = T::Response, Error = T::Error, Future = T::Future> + Send> in clone_box() argument
|
| /aosp_15_r20/prebuilts/runtime/mainline/platform/sdk/include/external/perfetto/include/perfetto/ext/base/threading/ |
| H A D | future.h | 79 explicit Future(std::unique_ptr<FuturePollable<T>> pollable) in Future() function
84 Future(T item) : pollable_(new ImmediateImpl<T>(std::move(item))) {} in Future() function
92 Future(Status status) : Future(T(std::move(status))) {} in Future() function
97 Future(typename U::value_type val) : Future(T(std::move(val))) {} in Future() function
|
| /aosp_15_r20/external/perfetto/include/perfetto/ext/base/threading/ |
| H A D | future.h | 79 explicit Future(std::unique_ptr<FuturePollable<T>> pollable) in Future() function
84 Future(T item) : pollable_(new ImmediateImpl<T>(std::move(item))) {} in Future() function
92 Future(Status status) : Future(T(std::move(status))) {} in Future() function
97 Future(typename U::value_type val) : Future(T(std::move(val))) {} in Future() function
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tonic/src/client/ |
| D | service.rs | 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()
41 type Future = T::Future; typedef
47 fn call(&mut self, request: http::Request<ReqBody>) -> Self::Future { in call()
|
| /aosp_15_r20/packages/modules/Bluetooth/system/rust/src/core/ |
| D | ffi.rs | 27 unsafe impl Send for Future {} implementation
53 type Future; typedef
57 fn future_ready(future: Pin<&mut Future>); in future_ready()
82 on_started: Pin<&'static mut Future>, in start()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/src/filter/ |
| D | predicate.rs | 9 type Future: Future<Output = Result<Self::Request, BoxError>>; typedef
22 fn check(&mut self, request: Request) -> Self::Future; in check()
46 type Future = futures_util::future::ErrInto<U, BoxError>; typedef
49 fn check(&mut self, request: T) -> Self::Future { in check()
|
| D | mod.rs | 108 type Future = ResponseFuture<T::Response, T::Future>; typedef
114 fn call(&mut self, request: Request) -> Self::Future { in call()
170 type Future = AsyncResponseFuture<U, T, Request>; typedef
176 fn call(&mut self, request: Request) -> Self::Future { in call()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/client/connect/ |
| D | dns.rs | 114 type Future = GaiFuture; typedef
120 fn call(&mut self, name: Name) -> Self::Future { in call()
331 type Future: Future<Output = Result<Self::Addrs, Self::Error>>; typedef
334 fn resolve(&mut self, name: Name) -> Self::Future; in resolve()
345 type Future = S::Future; typedef
351 fn resolve(&mut self, name: Name) -> Self::Future { in resolve()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/src/hedge/ |
| D | mod.rs | 175 type Future = Future<Service<S, P>, Request>; typedef
181 fn call(&mut self, request: Request) -> Self::Future { in call()
188 impl<S, Request> std::future::Future for Future<S, Request> implementation
225 type Future = future::Either< typedef
231 fn check(&mut self, request: Request) -> Self::Future { in check()
|
| /aosp_15_r20/prebuilts/go/linux-x86/test/fixedbugs/issue5910.dir/ |
| D | a.go | 11 type Future struct { struct
12 result chan struct {
18 func (t *Future) Result() (*Package, error) {
|