Lines Matching refs:tasks
9 let mut tasks = SelectAll::new(); in is_terminated() localVariable
11 assert_eq!(tasks.is_terminated(), false); in is_terminated()
12 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(None)); in is_terminated()
13 assert_eq!(tasks.is_terminated(), true); in is_terminated()
16 assert_eq!(tasks.is_empty(), true); in is_terminated()
17 assert_eq!(tasks.len(), 0); in is_terminated()
19 tasks.push(future::ready(1).into_stream()); in is_terminated()
21 assert_eq!(tasks.is_empty(), false); in is_terminated()
22 assert_eq!(tasks.len(), 1); in is_terminated()
24 assert_eq!(tasks.is_terminated(), false); in is_terminated()
25 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(Some(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(None)); in is_terminated()
28 assert_eq!(tasks.is_terminated(), true); in is_terminated()