obeli-sk-utils 0.41.4

Internal package of obelisk
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! Task spawning helpers that attach a name visible in `tokio-console`.
//!
//! `tokio::task::Builder::name` only exists under `--cfg tokio_unstable`
//! (the same flag `tokio-console` needs), so the named path is compiled in
//! only then; otherwise these fall back to plain `tokio::spawn`.

use std::future::Future;
use tokio::task::JoinHandle;

/// Spawn a task carrying `name`, shown in `tokio-console`.
#[cfg(tokio_unstable)]
pub fn spawn_named<F>(name: &str, future: F) -> JoinHandle<F::Output>
where
    F: Future + Send + 'static,
    F::Output: Send + 'static,
{
    tokio::task::Builder::new()
        .name(name)
        .spawn(future)
        .expect("spawning a task never fails")
}

/// Spawn a task carrying `name`, shown in `tokio-console`.
#[cfg(not(tokio_unstable))]
pub fn spawn_named<F>(_name: &str, future: F) -> JoinHandle<F::Output>
where
    F: Future + Send + 'static,
    F::Output: Send + 'static,
{
    tokio::spawn(future)
}