diff options
Diffstat (limited to 'tokio/src/runtime/blocking/pool.rs')
| -rw-r--r-- | tokio/src/runtime/blocking/pool.rs | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/tokio/src/runtime/blocking/pool.rs b/tokio/src/runtime/blocking/pool.rs index d0f2c1c8..2967a109 100644 --- a/tokio/src/runtime/blocking/pool.rs +++ b/tokio/src/runtime/blocking/pool.rs @@ -72,10 +72,7 @@ where F: FnOnce() -> R + Send + 'static, { let rt = context::current().expect("not currently running on the Tokio runtime."); - - let (task, handle) = task::joinable(BlockingTask::new(func)); - let _ = rt.blocking_spawner.spawn(task, &rt); - handle + rt.spawn_blocking(func) } #[allow(dead_code)] |