Lines Matching full:tasks
11 let mut tasks = SelectAll::new(); in is_terminated() localVariable
13 assert_eq!(tasks.is_terminated(), false); in is_terminated()
14 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(None)); in is_terminated()
15 assert_eq!(tasks.is_terminated(), true); in is_terminated()
18 assert_eq!(tasks.is_empty(), true); in is_terminated()
19 assert_eq!(tasks.len(), 0); in is_terminated()
21 tasks.push(future::ready(1).into_stream()); in is_terminated()
23 assert_eq!(tasks.is_empty(), false); in is_terminated()
24 assert_eq!(tasks.len(), 1); in is_terminated()
26 assert_eq!(tasks.is_terminated(), false); in is_terminated()
27 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(Some(1))); in is_terminated()
28 assert_eq!(tasks.is_terminated(), false); in is_terminated()
29 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(None)); in is_terminated()
30 assert_eq!(tasks.is_terminated(), true); in is_terminated()
82 let mut tasks = in clear() localVariable
85 assert_eq!(block_on(tasks.next()), Some(1)); in clear()
86 assert!(!tasks.is_empty()); in clear()
88 tasks.clear(); in clear()
89 assert!(tasks.is_empty()); in clear()
91 tasks.push(stream::iter(vec![3].into_iter())); in clear()
92 assert!(!tasks.is_empty()); in clear()
94 tasks.clear(); in clear()
95 assert!(tasks.is_empty()); in clear()
97 assert_eq!(block_on(tasks.next()), None); in clear()
98 assert!(tasks.is_terminated()); in clear()
99 tasks.clear(); in clear()
100 assert!(!tasks.is_terminated()); in clear()