1 | use futures::future::{self, FutureExt}; |
---|---|
2 | use futures::task::Context; |
3 | use futures_test::task::panic_waker; |
4 | |
5 | #[test] |
6 | fn fuse() { |
7 | let mut future = future::ready::<i32>(2).fuse(); |
8 | let waker = panic_waker(); |
9 | let mut cx = Context::from_waker(&waker); |
10 | assert!(future.poll_unpin(&mut cx).is_ready()); |
11 | assert!(future.poll_unpin(&mut cx).is_pending()); |
12 | } |
13 |