Searched refs:new_count_waker (Results 1 – 8 of 8) sorted by relevance
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio-util/tests/ |
| D | sync_cancellation_token.rs | 9 use futures_test::task::new_count_waker;
13 let (waker, wake_counter) = new_count_waker(); in cancel_token()
45 let (waker, wake_counter) = new_count_waker(); in cancel_token_owned()
77 let (waker, wake_counter) = new_count_waker(); in cancel_token_owned_drop_test()
95 let (waker, wake_counter) = new_count_waker(); in cancel_child_token_through_parent()
133 let (waker, wake_counter) = new_count_waker(); in cancel_grandchild_token_through_parent_if_child_was_dropped()
173 let (waker, wake_counter) = new_count_waker(); in cancel_child_token_without_parent()
238 let (waker, wake_counter) = new_count_waker(); in create_child_token_after_parent_was_cancelled()
300 let (waker, wake_counter) = new_count_waker(); in cancel_only_all_descendants()
452 let (waker, _) = new_count_waker(); in run_until_cancelled_test()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures/tests/ |
| D | future_abortable.rs | 5 use futures_test::task::new_count_waker;
22 let (waker, counter) = new_count_waker(); in abortable_awakens()
|
| D | stream_abortable.rs | 6 use futures_test::task::new_count_waker;
24 let (waker, counter) = new_count_waker(); in abortable_awakens()
|
| D | stream_select_next_some.rs | 7 use futures_test::task::new_count_waker;
11 let (waker, counter) = new_count_waker(); in is_terminated()
|
| D | lock_mutex.rs | 8 use futures_test::task::{new_count_waker, panic_context};
22 let (waker, counter) = new_count_waker(); in mutex_wakes_waiters()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures-channel/tests/ |
| D | mpsc.rs | 8 use futures_test::task::{new_count_waker, noop_context};
596 let (waker, counter) = new_count_waker(); in send_backpressure()
617 let (waker, counter) = new_count_waker(); in send_backpressure_multi_senders()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures-test/src/task/ |
| D | mod.rs | 60 pub use self::wake_counter::{new_count_waker, AwokenCount};
|
| D | wake_counter.rs | 56 pub fn new_count_waker() -> (Waker, AwokenCount) { in new_count_waker() function
|