Jon Häggblad
eb07ec8580
* common/task: rename ShutdownNotifier to TaskManager * nym-client: return boxed error * nym-client: enable graceful shutdown * nym-client: task wait on shutdown to instead exit on closed channel * Fix build * Fix unused * changelog: update
34 lines
770 B
Rust
34 lines
770 B
Rust
use crate::TaskClient;
|
|
use std::future::Future;
|
|
|
|
#[cfg(target_arch = "wasm32")]
|
|
pub(crate) fn spawn<F>(future: F)
|
|
where
|
|
F: Future<Output = ()> + 'static,
|
|
{
|
|
wasm_bindgen_futures::spawn_local(future);
|
|
}
|
|
|
|
#[cfg(not(target_arch = "wasm32"))]
|
|
pub(crate) fn spawn<F>(future: F)
|
|
where
|
|
F: Future + Send + 'static,
|
|
F::Output: Send + 'static,
|
|
{
|
|
tokio::spawn(future);
|
|
}
|
|
|
|
pub fn spawn_with_report_error<F, T, E>(future: F, mut shutdown: TaskClient)
|
|
where
|
|
F: Future<Output = Result<T, E>> + Send + 'static,
|
|
T: 'static,
|
|
E: std::error::Error + Send + Sync + 'static,
|
|
{
|
|
let future_that_sends = async move {
|
|
if let Err(err) = future.await {
|
|
shutdown.send_we_stopped(Box::new(err));
|
|
}
|
|
};
|
|
spawn(future_that_sends);
|
|
}
|