diff options
-rw-r--r-- | cli/ops.rs | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/cli/ops.rs b/cli/ops.rs index 56569c37a..bf4016366 100644 --- 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(), + )))) } } |