Git-Mirrors/veilid
1
0
Fork 0
mirror of https://gitlab.com/veilid/veilid.git synced 2025-03-29 00:58:09 -04:00
Code Issues Packages Projects Releases Wiki Activity

more fix

Browse Source
This commit is contained in:
Christien Rioux 2024-08-01 20:30:21 -05:00
parent 9005e0718e
commit 2440476564
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
veilid-tools/src/spawn.rs
View File

@ -57,6 +57,7 @@ cfg_if! {
} else if #[cfg(all(feature="rt-tokio", feature="tracing"))] { } else if #[cfg(all(feature="rt-tokio", feature="tracing"))] {
MustJoinHandle::new(tokio::task::Builder::new().name(name).spawn(future).unwrap()) MustJoinHandle::new(tokio::task::Builder::new().name(name).spawn(future).unwrap())
} else if #[cfg(feature="rt-tokio")] { } else if #[cfg(feature="rt-tokio")] {
let _name = name;
MustJoinHandle::new(tokio::task::spawn(future)) MustJoinHandle::new(tokio::task::spawn(future))
} }
} }
@ -72,6 +73,7 @@ cfg_if! {
} else if #[cfg(all(feature="rt-tokio", feature="tracing"))] { } else if #[cfg(all(feature="rt-tokio", feature="tracing"))] {
MustJoinHandle::new(tokio::task::Builder::new().name(name).spawn_local(future).unwrap()) MustJoinHandle::new(tokio::task::Builder::new().name(name).spawn_local(future).unwrap())
} else if #[cfg(feature="rt-tokio")] { } else if #[cfg(feature="rt-tokio")] {
let _name = name;
MustJoinHandle::new(tokio::task::spawn_local(future)) MustJoinHandle::new(tokio::task::spawn_local(future))
} }
} }
@ -87,6 +89,7 @@ cfg_if! {
} else if #[cfg(all(feature="rt-tokio", feature="tracing"))] { } else if #[cfg(all(feature="rt-tokio", feature="tracing"))] {
drop(tokio::task::Builder::new().name(name).spawn(future).unwrap()); drop(tokio::task::Builder::new().name(name).spawn(future).unwrap());
} else if #[cfg(feature="rt-tokio")] { } else if #[cfg(feature="rt-tokio")] {
let _name = name;
drop(tokio::task::spawn(future)) drop(tokio::task::spawn(future))
} }
} }
@ -102,6 +105,7 @@ cfg_if! {
} else if #[cfg(all(feature="rt-tokio", feature="tracing"))] { } else if #[cfg(all(feature="rt-tokio", feature="tracing"))] {
drop(tokio::task::Builder::new().name(name).spawn_local(future).unwrap()); drop(tokio::task::Builder::new().name(name).spawn_local(future).unwrap());
} else if #[cfg(feature="rt-tokio")] { } else if #[cfg(feature="rt-tokio")] {
let _name = name;
drop(tokio::task::spawn_local(future)) drop(tokio::task::spawn_local(future))
} }
} }
@ -122,6 +126,7 @@ cfg_if! {
} else if #[cfg(all(feature="rt-tokio", feature="tracing"))] { } else if #[cfg(all(feature="rt-tokio", feature="tracing"))] {
tokio::task::Builder::new().name(name).spawn_blocking(blocking_task).unwrap().await.unwrap_or(err_result) tokio::task::Builder::new().name(name).spawn_blocking(blocking_task).unwrap().await.unwrap_or(err_result)
} else if #[cfg(feature="rt-tokio")] { } else if #[cfg(feature="rt-tokio")] {
let _name = name;
tokio::task::spawn_blocking(blocking_task).await.unwrap_or(err_result) tokio::task::spawn_blocking(blocking_task).await.unwrap_or(err_result)
} else { } else {
#[compile_error("must use an executor")] #[compile_error("must use an executor")]