1 use futures::future::{self, FutureExt}; 2 use futures::task::Context; 3 use futures_test::task::panic_waker; 4 5 #[test] fuse()6fn 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