use futures::future::{self, FutureExt}; use futures::task::Context; use futures_test::task::panic_waker; #[test] fn fuse() { let mut future = future::ready::(2).fuse(); let waker = panic_waker(); let mut cx = Context::from_waker(&waker); assert!(future.poll_unpin(&mut cx).is_ready()); assert!(future.poll_unpin(&mut cx).is_pending()); }