yaaral 0.5.3

yet another async runtime abstraction library
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

/// The contained struct should not be dropped, this will panic.
pub struct TaskHandle<T>(Option<T>)
where
    T: crate::TaskHandle;

impl<T> Drop for TaskHandle<T>
where
    T: crate::TaskHandle,
{
    fn drop(&mut self) {
        if self.0.is_some() {
            panic!("Should be cancelled, joined or detached, before dropping.");
        }
    }
}

impl<T> crate::TaskHandle for TaskHandle<T>
where
    T: crate::TaskHandle,
{
    type Output = T::Output;
    type JoinError = T::JoinError;
    fn join(mut self) -> impl Future<Output = Result<Self::Output, Self::JoinError>> {
        self.0.take().unwrap().join()
    }
    fn abort(mut self) {
        self.0.take().unwrap().abort();
    }
    fn cancel(mut self) -> impl Future<Output = ()> {
        self.0.take().unwrap().cancel()
    }
    fn detach(mut self) {
        self.0.take().unwrap().detach();
    }
}

impl<T> From<T> for TaskHandle<T>
where
    T: crate::TaskHandle,
{
    fn from(value: T) -> Self {
        Self(Some(value))
    }
}

/// Used when function actually never return an error
#[derive(Debug)]
pub struct Infallible {}

impl std::fmt::Display for Infallible {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "Infallible.")
    }
}

impl std::error::Error for Infallible {
    fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
        None
    }
}