| /external/rust/crates/tokio-test/src/ |
| D | macros.rs | 23 macro_rules! assert_ready { macro
64 use tokio_test::{assert_ready, assert_ok};
65 let val = assert_ready!($e);
69 use tokio_test::{assert_ready, assert_ok};
70 let val = assert_ready!($e, $($msg)*);
97 use tokio_test::{assert_ready, assert_err};
98 let val = assert_ready!($e);
102 use tokio_test::{assert_ready, assert_err};
103 let val = assert_ready!($e, $($msg)*);
169 let val = $crate::assert_ready!($e);
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | sync_barrier.rs | 8 use tokio_test::{assert_pending, assert_ready};
23 let wr = assert_ready!(w.poll()); in zero_does_not_block()
28 let wr = assert_ready!(w.poll()); in zero_does_not_block()
39 let wr = assert_ready!(w.poll()); in single()
44 let wr = assert_ready!(w.poll()); in single()
49 let wr = assert_ready!(w.poll()); in single()
62 let wr2 = assert_ready!(w2.poll()); in tango()
63 let wr1 = assert_ready!(w1.poll()); in tango()
86 let mut found_leader = assert_ready!(w.poll()).is_leader(); in lots()
88 let wr = assert_ready!(w.poll()); in lots()
|
| D | sync_rwlock.rs | 12 use tokio_test::{assert_pending, assert_ready};
26 let _g1 = assert_ready!(t1.poll()); in read_shared()
28 assert_ready!(t2.poll()); in read_shared()
37 let _g1 = assert_ready!(t1.poll()); in write_shared_pending()
48 let _g1 = assert_ready!(t1.poll()); in read_exclusive_pending()
72 assert_ready!(t1.poll()); in exhaust_reading()
81 let _g1 = assert_ready!(t1.poll()); in write_exclusive_pending()
92 let g1 = assert_ready!(t1.poll()); in write_shared_drop()
97 assert_ready!(t2.poll()); in write_shared_drop()
106 let _g1 = assert_ready!(t1.poll()); in write_read_shared_pending()
[all …]
|
| D | sync_notify.rs | 17 assert_ready!(notified.poll()); in notify_notified_one()
29 assert_ready!(notified.poll()); in notified_one_notify()
45 assert_ready!(notified1.poll()); in notified_multi_notify()
58 assert_ready!(notified1.poll()); in notify_notified_multi()
64 assert_ready!(notified2.poll()); in notify_notified_multi()
81 assert_ready!(notified2.poll()); in notified_drop_notified_notify()
101 assert_ready!(notified2.poll()); in notified_multi_notify_drop_one()
152 assert_ready!(notified2.poll()); in notify_one_after_dropped_all()
|
| D | sync_mutex_owned.rs | 7 use tokio_test::{assert_pending, assert_ready};
18 let mut g = assert_ready!(t.poll()); in straight_execution()
24 let mut g = assert_ready!(t.poll()); in straight_execution()
30 let g = assert_ready!(t.poll()); in straight_execution()
41 let g = assert_ready!(t1.poll()); in readiness()
49 assert_ready!(t2.poll()); in readiness()
|
| D | sync_mutex.rs | 7 use tokio_test::{assert_pending, assert_ready};
18 let mut g = assert_ready!(t.poll()); in straight_execution()
24 let mut g = assert_ready!(t.poll()); in straight_execution()
30 let g = assert_ready!(t.poll()); in straight_execution()
42 let g = assert_ready!(t1.poll()); in readiness()
50 assert_ready!(t2.poll()); in readiness()
|
| D | io_driver_drop.rs | 6 use tokio_test::{assert_err, assert_pending, assert_ready, task};
24 assert_ready!(task.poll()); in tcp_doesnt_block()
46 assert_ready!(task.poll()); in drop_wakes()
|
| D | macros_try_join.rs | 3 use tokio_test::{assert_pending, assert_ready, task};
49 let res: Result<(&str, u32), _> = assert_ready!(join.poll()); in two_await()
75 let res = assert_ready!(join.poll()); in err_abort_early()
|
| D | sync_oneshot.rs | 83 assert_ready!(tx.enter(|cx, mut tx| tx.poll_closed(cx))); in close_rx()
123 assert_ready!(tx.enter(|cx, mut tx| tx.poll_closed(cx))); in explicit_close_poll()
139 assert_ready!(tx.enter(|cx, mut tx| tx.poll_closed(cx))); in explicit_close_poll()
166 assert_ready!(tx.enter(|cx, mut tx| tx.poll_closed(cx))); in explicit_close_try_recv()
268 assert_ready!(task2.enter(|cx, _| tx.poll_closed(cx))); in sender_changes_task()
|
| D | macros_join.rs | 3 use tokio_test::{assert_pending, assert_ready, task};
50 let res = assert_ready!(join.poll()); in two_await()
|
| D | sync_watch.rs | 7 use tokio_test::{assert_pending, assert_ready, assert_ready_err, assert_ready_ok};
167 assert_ready!(t.poll()); in poll_close()
|
| D | macros_select.rs | 4 use tokio_test::{assert_ok, assert_pending, assert_ready};
297 let res = assert_ready!(f.poll()); in future_panics_after_poll()
320 assert_ready!(f.poll()); in disable_with_if()
352 let (a, b) = assert_ready!(f.poll()); in join_with_select()
|
| D | time_sleep.rs | 10 use tokio_test::{assert_pending, assert_ready, task};
182 assert_ready!(sleep.poll()); in reset_sleep_to_past()
276 assert_ready!(timer in reset_after_firing()
|
| D | sync_mpsc.rs | 11 assert_err, assert_ok, assert_pending, assert_ready, assert_ready_err, assert_ready_ok,
296 let v = assert_ready!(recv.poll()); in recv_close_gets_none_reserved()
475 let val = assert_ready!(recv.poll()); in ready_close_cancel_bounded()
|
| D | sync_broadcast.rs | 8 assert_err, assert_ok, assert_pending, assert_ready, assert_ready_err, assert_ready_ok,
|
| D | fs_file_mocked.rs | 66 use tokio_test::{assert_pending, assert_ready, assert_ready_err, assert_ready_ok, task};
|
| /external/rust/crates/tokio-test/tests/ |
| D | macros.rs | 5 assert_pending, assert_ready, assert_ready_eq, assert_ready_err, assert_ready_ok,
30 fn assert_ready() { in assert_ready() function
32 assert_ready!(poll); in assert_ready()
33 assert_ready!(poll, "some message"); in assert_ready()
34 assert_ready!(poll, "{:?}", ()); in assert_ready()
35 assert_ready!(poll, "{:?}", Test::Data); in assert_ready()
42 assert_ready!(poll); in assert_ready_on_pending()
|
| /external/rust/crates/tokio-stream/tests/ |
| D | stream_merge.rs | 3 use tokio_test::{assert_pending, assert_ready};
38 assert_eq!(Some(1), assert_ready!(rx.poll_next())); in merge_async_streams()
44 assert_eq!(Some(2), assert_ready!(rx.poll_next())); in merge_async_streams()
53 assert_eq!(Some(3), assert_ready!(rx.poll_next())); in merge_async_streams()
58 assert_eq!(None, assert_ready!(rx.poll_next())); in merge_async_streams()
|
| D | stream_chain.rs | 2 use tokio_test::{assert_pending, assert_ready, task};
59 assert_eq!(Some(1), assert_ready!(stream.poll_next())); in pending_first()
68 assert_eq!(Some(2), assert_ready!(stream.poll_next())); in pending_first()
75 assert_eq!(None, assert_ready!(stream.poll_next())); in pending_first()
|
| D | stream_collect.rs | 2 use tokio_test::{assert_pending, assert_ready, assert_ready_err, assert_ready_ok, task};
60 let coll = assert_ready!(fut.poll()); in collect_vec_items()
82 let coll = assert_ready!(fut.poll()); in collect_string_items()
104 let coll = assert_ready!(fut.poll()); in collect_str_items()
|
| D | time_throttle.rs | 16 assert_ready!(stream.poll_next()); in usage()
27 assert_ready!(stream.poll_next()); in usage()
|
| D | stream_timeout.rs | 39 let v = assert_ready!(stream.poll_next()); in basic_usage()
57 let v = assert_ready!(stream.poll_next()); in basic_usage()
82 let v = assert_ready!(stream.poll_next()); in return_elapsed_errors_only_once()
|
| D | stream_stream_map.rs | 2 use tokio_test::{assert_ok, assert_pending, assert_ready, task};
14 match assert_ready!($($t)*) {
23 match assert_ready!($($t)*) {
|
| /external/rust/crates/tokio/src/ |
| D | coop.rs | 225 let coop = assert_ready!(task::spawn(()).enter(|cx, _| poll_proceed(cx))); in bugeting()
234 let coop = assert_ready!(task::spawn(()).enter(|cx, _| poll_proceed(cx))); in bugeting()
240 let coop = assert_ready!(task::spawn(()).enter(|cx, _| poll_proceed(cx))); in bugeting()
247 let coop = assert_ready!(task::spawn(()).enter(|cx, _| poll_proceed(cx))); in bugeting()
256 let coop = assert_ready!(task::spawn(()).enter(|cx, _| poll_proceed(cx))); in bugeting()
272 let coop = assert_ready!(task::spawn(()).enter(|cx, _| poll_proceed(cx))); in bugeting()
|