fix: run blocking function on a different task (denoland#2570)

This avoids freezing the current task if the fn blocks indefinitely
J2P · Jun 26, 2019 · fb6d57a · fb6d57a
1 parent 6906a2f
commit fb6d57a
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/cli/ops.rs b/cli/ops.rs
@@ -793,9 +793,10 @@ where
     let result_buf = f()?;
     Ok(Op::Sync(result_buf))
   } else {
-    Ok(Op::Async(Box::new(tokio_util::poll_fn(move || {
-      convert_blocking(f)
-    }))))
+    Ok(Op::Async(Box::new(futures::sync::oneshot::spawn(
+      tokio_util::poll_fn(move || convert_blocking(f)),
+      &tokio_executor::DefaultExecutor::current(),
+    ))))
   }
 }