summaryrefslogtreecommitdiffstats
path: root/tokio/src/runtime/thread_pool
diff options
context:
space:
mode:
authorCarl Lerche <me@carllerche.com>2019-11-16 23:35:04 -0800
committerGitHub <noreply@github.com>2019-11-16 23:35:04 -0800
commitb1d9e55487d8411da89788ce0fbb3eb99a1f3a40 (patch)
tree4561bcaec9e2b011e6741c7fdc84fdefa1716deb /tokio/src/runtime/thread_pool
parent66cbed3ce302e43f18c7d0a6673886404570fb39 (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.rs4
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(());
})
});