55     let mut fut = task::spawn(rx.collect::<Vec<i32>>());  in collect_vec_items()  localVariable
57     assert_pending!(fut.poll());  in collect_vec_items()
60     assert!(fut.is_woken());  in collect_vec_items()
61     assert_pending!(fut.poll());  in collect_vec_items()
64     assert!(fut.is_woken());  in collect_vec_items()
65     assert_pending!(fut.poll());  in collect_vec_items()
68     assert!(fut.is_woken());  in collect_vec_items()
69     let coll = assert_ready!(fut.poll());  in collect_vec_items()
76     let mut fut = task::spawn(rx.collect::<String>());  in collect_string_items()  localVariable
78     assert_pending!(fut.poll());  in collect_string_items()
81     assert!(fut.is_woken());  in collect_string_items()
82     assert_pending!(fut.poll());  in collect_string_items()
85     assert!(fut.is_woken());  in collect_string_items()
86     assert_pending!(fut.poll());  in collect_string_items()
89     assert!(fut.is_woken());  in collect_string_items()
90     let coll = assert_ready!(fut.poll());  in collect_string_items()
97     let mut fut = task::spawn(rx.collect::<String>());  in collect_str_items()  localVariable
99     assert_pending!(fut.poll());  in collect_str_items()
102     assert!(fut.is_woken());  in collect_str_items()
103     assert_pending!(fut.poll());  in collect_str_items()
106     assert!(fut.is_woken());  in collect_str_items()
107     assert_pending!(fut.poll());  in collect_str_items()
110     assert!(fut.is_woken());  in collect_str_items()
111     let coll = assert_ready!(fut.poll());  in collect_str_items()
118     let mut fut = task::spawn(rx.collect::<Bytes>());  in collect_bytes()  localVariable
120     assert_pending!(fut.poll());  in collect_bytes()
123     assert!(fut.is_woken());  in collect_bytes()
124     assert_pending!(fut.poll());  in collect_bytes()
127     assert!(fut.is_woken());  in collect_bytes()
128     assert_pending!(fut.poll());  in collect_bytes()
131     assert!(fut.is_woken());  in collect_bytes()
132     let coll = assert_ready!(fut.poll());  in collect_bytes()
139     let mut fut = task::spawn(rx.collect::<Result<String, &str>>());  in collect_results_ok()  localVariable
141     assert_pending!(fut.poll());  in collect_results_ok()
144     assert!(fut.is_woken());  in collect_results_ok()
145     assert_pending!(fut.poll());  in collect_results_ok()
148     assert!(fut.is_woken());  in collect_results_ok()
149     assert_pending!(fut.poll());  in collect_results_ok()
152     assert!(fut.is_woken());  in collect_results_ok()
153     let coll = assert_ready_ok!(fut.poll());  in collect_results_ok()
160     let mut fut = task::spawn(rx.collect::<Result<String, &str>>());  in collect_results_err()  localVariable
162     assert_pending!(fut.poll());  in collect_results_err()
165     assert!(fut.is_woken());  in collect_results_err()
166     assert_pending!(fut.poll());  in collect_results_err()
169     assert!(fut.is_woken());  in collect_results_err()
170     let err = assert_ready_err!(fut.poll());  in collect_results_err()