fn main() { let f = future::poll_fn(move || { match tokio_threadpool::blocking(|| f.poll()).unwrap() { Async::Ready(v) => v, Async::NotReady => Ok(Async::NotReady), } }); }