Lines Matching refs:map
32 let mut map = StreamMap::<&str, stream::Pending<()>>::new(); in empty() localVariable
34 assert_eq!(map.len(), 0); in empty()
35 assert!(map.is_empty()); in empty()
37 assert!(map.next().await.is_none()); in empty()
38 assert!(map.next().await.is_none()); in empty()
40 assert!(map.remove("foo").is_none()); in empty()
45 let mut map = task::spawn(StreamMap::new()); in single_entry() localVariable
49 assert_ready_none!(map.poll_next()); in single_entry()
51 assert!(map.insert("foo", rx).is_none()); in single_entry()
52 assert!(map.contains_key("foo")); in single_entry()
53 assert!(!map.contains_key("bar")); in single_entry()
55 assert_eq!(map.len(), 1); in single_entry()
56 assert!(!map.is_empty()); in single_entry()
58 assert_pending!(map.poll_next()); in single_entry()
62 assert!(map.is_woken()); in single_entry()
63 let (k, v) = assert_ready_some!(map.poll_next()); in single_entry()
67 assert_pending!(map.poll_next()); in single_entry()
71 assert!(map.is_woken()); in single_entry()
72 let (k, v) = assert_ready_some!(map.poll_next()); in single_entry()
76 assert_pending!(map.poll_next()); in single_entry()
78 assert!(map.is_woken()); in single_entry()
79 assert_ready_none!(map.poll_next()); in single_entry()
84 let mut map = task::spawn(StreamMap::new()); in multiple_entries() localVariable
91 map.insert("foo", rx1); in multiple_entries()
92 map.insert("bar", rx2); in multiple_entries()
94 assert_pending!(map.poll_next()); in multiple_entries()
98 assert!(map.is_woken()); in multiple_entries()
99 let (k, v) = assert_ready_some!(map.poll_next()); in multiple_entries()
103 assert_pending!(map.poll_next()); in multiple_entries()
107 assert!(map.is_woken()); in multiple_entries()
108 let (k, v) = assert_ready_some!(map.poll_next()); in multiple_entries()
112 assert_pending!(map.poll_next()); in multiple_entries()
117 assert!(map.is_woken()); in multiple_entries()
122 .map(|_| assert_ready_some!(map.poll_next())) in multiple_entries()
125 assert_pending!(map.poll_next()); in multiple_entries()
134 assert!(map.is_woken()); in multiple_entries()
135 assert_pending!(map.poll_next()); in multiple_entries()
138 assert_ready_none!(map.poll_next()); in multiple_entries()
143 let mut map = task::spawn(StreamMap::new()); in insert_remove() localVariable
148 assert_ready_none!(map.poll_next()); in insert_remove()
150 assert!(map.insert("foo", rx).is_none()); in insert_remove()
151 let rx = map.remove("foo").unwrap(); in insert_remove()
155 assert!(!map.is_woken()); in insert_remove()
156 assert_ready_none!(map.poll_next()); in insert_remove()
158 assert!(map.insert("bar", rx).is_none()); in insert_remove()
160 let v = assert_ready_some!(map.poll_next()); in insert_remove()
164 assert!(map.remove("bar").is_some()); in insert_remove()
165 assert_ready_none!(map.poll_next()); in insert_remove()
167 assert!(map.is_empty()); in insert_remove()
168 assert_eq!(0, map.len()); in insert_remove()
173 let mut map = task::spawn(StreamMap::new()); in replace() localVariable
180 assert!(map.insert("foo", rx1).is_none()); in replace()
182 assert_pending!(map.poll_next()); in replace()
184 let _rx1 = map.insert("foo", rx2).unwrap(); in replace()
186 assert_pending!(map.poll_next()); in replace()
189 assert_pending!(map.poll_next()); in replace()
192 assert!(map.is_woken()); in replace()
193 let v = assert_ready_some!(map.poll_next()); in replace()
200 let mut map = StreamMap::new(); in size_hint_with_upper() localVariable
202 map.insert("a", stream::iter(vec![1])); in size_hint_with_upper()
203 map.insert("b", stream::iter(vec![1, 2])); in size_hint_with_upper()
204 map.insert("c", stream::iter(vec![1, 2, 3])); in size_hint_with_upper()
206 assert_eq!(3, map.len()); in size_hint_with_upper()
207 assert!(!map.is_empty()); in size_hint_with_upper()
209 let size_hint = map.size_hint(); in size_hint_with_upper()
215 let mut map = StreamMap::new(); in size_hint_without_upper() localVariable
217 map.insert("a", pin_box(stream::iter(vec![1]))); in size_hint_without_upper()
218 map.insert("b", pin_box(stream::iter(vec![1, 2]))); in size_hint_without_upper()
219 map.insert("c", pin_box(pending())); in size_hint_without_upper()
221 let size_hint = map.size_hint(); in size_hint_without_upper()
227 let map = StreamMap::<&str, stream::Pending<()>>::new(); in new_capacity_zero() localVariable
228 assert_eq!(0, map.capacity()); in new_capacity_zero()
230 assert!(map.keys().next().is_none()); in new_capacity_zero()
235 let map = StreamMap::<&str, stream::Pending<()>>::with_capacity(10); in with_capacity() localVariable
236 assert!(10 <= map.capacity()); in with_capacity()
238 assert!(map.keys().next().is_none()); in with_capacity()
243 let mut map = StreamMap::new(); in iter_keys() localVariable
245 map.insert("a", pending::<i32>()); in iter_keys()
246 map.insert("b", pending()); in iter_keys()
247 map.insert("c", pending()); in iter_keys()
249 let mut keys = map.keys().collect::<Vec<_>>(); in iter_keys()
257 let mut map = StreamMap::new(); in iter_values() localVariable
259 map.insert("a", stream::iter(vec![1])); in iter_values()
260 map.insert("b", stream::iter(vec![1, 2])); in iter_values()
261 map.insert("c", stream::iter(vec![1, 2, 3])); in iter_values()
263 let mut size_hints = map.values().map(|s| s.size_hint().0).collect::<Vec<_>>(); in iter_values()
272 let mut map = StreamMap::new(); in iter_values_mut() localVariable
274 map.insert("a", stream::iter(vec![1])); in iter_values_mut()
275 map.insert("b", stream::iter(vec![1, 2])); in iter_values_mut()
276 map.insert("c", stream::iter(vec![1, 2, 3])); in iter_values_mut()
278 let mut size_hints = map in iter_values_mut()
280 .map(|s: &mut _| s.size_hint().0) in iter_values_mut()
290 let mut map = task::spawn(StreamMap::new()); in clear() localVariable
292 map.insert("a", stream::iter(vec![1])); in clear()
293 map.insert("b", stream::iter(vec![1, 2])); in clear()
294 map.insert("c", stream::iter(vec![1, 2, 3])); in clear()
296 assert_ready_some!(map.poll_next()); in clear()
298 map.clear(); in clear()
300 assert_ready_none!(map.poll_next()); in clear()
301 assert!(map.is_empty()); in clear()
306 let mut map = StreamMap::new(); in contains_key_borrow() localVariable
307 map.insert("foo".to_string(), pending::<()>()); in contains_key_borrow()
309 assert!(map.contains_key("foo")); in contains_key_borrow()
316 let mut map = task::spawn(StreamMap::new()); in one_ready_many_none() localVariable
318 map.insert(0, pin_box(stream::empty())); in one_ready_many_none()
319 map.insert(1, pin_box(stream::empty())); in one_ready_many_none()
320 map.insert(2, pin_box(stream::once("hello"))); in one_ready_many_none()
321 map.insert(3, pin_box(stream::pending())); in one_ready_many_none()
323 let v = assert_ready_some!(map.poll_next()); in one_ready_many_none()
350 let mut map = task::spawn(StreamMap::new()); localVariable
366 map.insert(i, stream);
370 assert_ready_none!(map.poll_next());
372 assert_pending!(map.poll_next());
374 assert_eq!(expect, map.values().count());
376 for stream in map.values() {