jarust_rt 1.8.2

A janus client SDK in Rust
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
32
33
34

use futures_util::Future;
use tokio::task::AbortHandle;

pub fn spawn<F>(name: &str, future: F) -> JaTask
where
    F: Future + Send + 'static,
    F::Output: Send + 'static,
{
    let jh = tokio::spawn(future);
    JaTask {
        inner: jh.abort_handle(),
        task_name: name.to_owned(),
    }
}

#[derive(Debug)]
pub struct JaTask {
    inner: AbortHandle,
    pub task_name: String,
}

impl JaTask {
    pub fn cancel(&self) {
        self.inner.abort();
    }
}

impl Drop for JaTask {
    #[tracing::instrument(level = tracing::Level::TRACE, skip_all)]
    fn drop(&mut self) {
        tracing::trace!(task_name = self.task_name, "Dropping task");
        self.cancel();
    }
}