Lines Matching refs:fut
46 let mut fut = task::spawn(rx.collect::<Vec<i32>>()); in collect_vec_items() localVariable
48 assert_pending!(fut.poll()); in collect_vec_items()
51 assert!(fut.is_woken()); in collect_vec_items()
52 assert_pending!(fut.poll()); in collect_vec_items()
55 assert!(fut.is_woken()); in collect_vec_items()
56 assert_pending!(fut.poll()); in collect_vec_items()
59 assert!(fut.is_woken()); in collect_vec_items()
60 let coll = assert_ready!(fut.poll()); in collect_vec_items()
68 let mut fut = task::spawn(rx.collect::<String>()); in collect_string_items() localVariable
70 assert_pending!(fut.poll()); in collect_string_items()
73 assert!(fut.is_woken()); in collect_string_items()
74 assert_pending!(fut.poll()); in collect_string_items()
77 assert!(fut.is_woken()); in collect_string_items()
78 assert_pending!(fut.poll()); in collect_string_items()
81 assert!(fut.is_woken()); in collect_string_items()
82 let coll = assert_ready!(fut.poll()); in collect_string_items()
90 let mut fut = task::spawn(rx.collect::<String>()); in collect_str_items() localVariable
92 assert_pending!(fut.poll()); in collect_str_items()
95 assert!(fut.is_woken()); in collect_str_items()
96 assert_pending!(fut.poll()); in collect_str_items()
99 assert!(fut.is_woken()); in collect_str_items()
100 assert_pending!(fut.poll()); in collect_str_items()
103 assert!(fut.is_woken()); in collect_str_items()
104 let coll = assert_ready!(fut.poll()); in collect_str_items()
112 let mut fut = task::spawn(rx.collect::<Result<String, &str>>()); in collect_results_ok() localVariable
114 assert_pending!(fut.poll()); in collect_results_ok()
117 assert!(fut.is_woken()); in collect_results_ok()
118 assert_pending!(fut.poll()); in collect_results_ok()
121 assert!(fut.is_woken()); in collect_results_ok()
122 assert_pending!(fut.poll()); in collect_results_ok()
125 assert!(fut.is_woken()); in collect_results_ok()
126 let coll = assert_ready_ok!(fut.poll()); in collect_results_ok()
134 let mut fut = task::spawn(rx.collect::<Result<String, &str>>()); in collect_results_err() localVariable
136 assert_pending!(fut.poll()); in collect_results_err()
139 assert!(fut.is_woken()); in collect_results_err()
140 assert_pending!(fut.poll()); in collect_results_err()
143 assert!(fut.is_woken()); in collect_results_err()
144 let err = assert_ready_err!(fut.poll()); in collect_results_err()