diff options
author | Carl Lerche <me@carllerche.com> | 2019-11-16 23:35:04 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-11-16 23:35:04 -0800 |
commit | b1d9e55487d8411da89788ce0fbb3eb99a1f3a40 (patch) | |
tree | 4561bcaec9e2b011e6741c7fdc84fdefa1716deb /tokio/src/runtime/thread_pool | |
parent | 66cbed3ce302e43f18c7d0a6673886404570fb39 (diff) |
task: move blocking fns into `tokio::task` (#1781)
Diffstat (limited to 'tokio/src/runtime/thread_pool')
-rw-r--r-- | tokio/src/runtime/thread_pool/tests/loom_pool.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tokio/src/runtime/thread_pool/tests/loom_pool.rs b/tokio/src/runtime/thread_pool/tests/loom_pool.rs index 7b8becf2..b982e24e 100644 --- a/tokio/src/runtime/thread_pool/tests/loom_pool.rs +++ b/tokio/src/runtime/thread_pool/tests/loom_pool.rs @@ -50,7 +50,7 @@ fn only_blocking() { let (block_tx, block_rx) = oneshot::channel(); pool.spawn(async move { - crate::blocking::in_place(move || { + crate::task::block_in_place(move || { block_tx.send(()); }) }); @@ -72,7 +72,7 @@ fn blocking_and_regular() { let done_tx = Arc::new(Mutex::new(Some(done_tx))); pool.spawn(async move { - crate::blocking::in_place(move || { + crate::task::block_in_place(move || { block_tx.send(()); }) }); |