We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 98c08f8 commit d4572c7Copy full SHA for d4572c7
src/task/executor.rs
@@ -46,6 +46,8 @@ where
46
let waker = async_task::waker_fn(move || unparker.unpark());
47
let cx = &mut Context::from_waker(&waker);
48
pin_utils::pin_mut!(future);
49
+ // Force initialization of async-io's Reactor before running.
50
+ executor.parker.park_timeout(std::time::Duration::from_millis(0));
51
loop {
52
if let Poll::Ready(res) = future.as_mut().poll(cx) {
53
return res;
0 commit comments