Searched defs:MyFuture (Results 1 – 8 of 8) sorted by relevance
/aosp_15_r20/external/rust/android-crates-io/crates/tokio/tests/ |
D | task_id.rs | 78 struct MyFuture { in task_id_future_destructor_completion() struct 79 tx: Option<oneshot::Sender<Id>>, in task_id_future_destructor_completion() 82 impl Future for MyFuture { in task_id_future_destructor_completion() implementation 90 impl Drop for MyFuture { in task_id_future_destructor_completion() implementation 106 struct MyFuture { in task_id_future_destructor_abort() struct 107 tx: Option<oneshot::Sender<Id>>, in task_id_future_destructor_abort() 110 impl Future for MyFuture { in task_id_future_destructor_abort() implementation 117 impl Drop for MyFuture { in task_id_future_destructor_abort() implementation 143 struct MyFuture { in task_id_output_destructor_handle_dropped_before_completion() struct 144 tx: Option<oneshot::Sender<Id>>, in task_id_output_destructor_handle_dropped_before_completion() [all …]
|
D | task_local.rs | 46 struct MyFuture { in task_local_available_on_abort() struct 47 tx_poll: Option<oneshot::Sender<()>>, in task_local_available_on_abort() 48 tx_drop: Option<oneshot::Sender<u32>>, in task_local_available_on_abort() 50 impl Future for MyFuture { in task_local_available_on_abort() implementation 60 impl Drop for MyFuture { in task_local_available_on_abort() implementation 97 struct MyFuture { in task_local_available_on_completion_drop() struct 98 tx: Option<oneshot::Sender<u32>>, in task_local_available_on_completion_drop() 100 impl Future for MyFuture { in task_local_available_on_completion_drop() implementation 107 impl Drop for MyFuture { in task_local_available_on_completion_drop() implementation
|
D | rt_threaded_alt.rs | 539 struct MyFuture { in wake_during_shutdown() struct 540 shared: Arc<Mutex<Shared>>, in wake_during_shutdown() 541 put_waker: bool, in wake_during_shutdown() 544 impl MyFuture { in wake_during_shutdown() implementation 559 impl Future for MyFuture { in wake_during_shutdown() implementation 572 impl Drop for MyFuture { in wake_during_shutdown() implementation
|
D | rt_threaded.rs | 542 struct MyFuture { in wake_during_shutdown() struct 543 shared: Arc<Mutex<Shared>>, in wake_during_shutdown() 544 put_waker: bool, in wake_during_shutdown() 547 impl MyFuture { in wake_during_shutdown() implementation 562 impl Future for MyFuture { in wake_during_shutdown() implementation 575 impl Drop for MyFuture { in wake_during_shutdown() implementation
|
/aosp_15_r20/external/libcxx/test/libcxx/experimental/language.support/support.coroutines/ |
H A D | dialect_support.sh.cpp | 27 struct MyFuture { struct 33 MyFuture get_return_object() { in get_return_object() argument 41 MyFuture() : p() {} in MyFuture() argument 42 MyFuture(HandleT h) : p(h) {} in MyFuture() function 47 MyFuture test_coro() { in test_coro() argument
|
/aosp_15_r20/external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/rpc/ |
H A D | FirstElementResponseObserver.java | 77 private class MyFuture extends AbstractApiFuture<ResponseT> { class in FirstElementResponseObserver
|
H A D | SpoolingResponseObserver.java | 76 class MyFuture extends AbstractApiFuture<List<ResponseT>> { class in SpoolingResponseObserver
|
/aosp_15_r20/external/python/cpython3/Lib/test/test_asyncio/ |
D | test_futures.py | 118 class MyFuture: class
|