moro 0.4.0

Experimental structured concurrency support for async Rust (similar to trio's nurseries)
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

use crate::Scope;

#[async_trait::async_trait]
pub trait UnwrapOrCancel: Send + Sized {
    type Ok: Send;
    type Err: Send;

    async fn unwrap_or_cancel<'scope, 'env, T>(
        self,
        scope: &'scope Scope<'scope, 'env, Result<T, Self::Err>>,
    ) -> Self::Ok
    where
        T: Send,
        Self: 'env;
}

#[async_trait::async_trait]
impl<O, E> UnwrapOrCancel for Result<O, E>
where
    O: Send,
    E: Send,
{
    type Ok = O;
    type Err = E;

    async fn unwrap_or_cancel<'scope, 'env, T>(
        self,
        scope: &'scope Scope<'scope, 'env, Result<T, E>>,
    ) -> O
    where
        T: Send,
        Self: 'env,
    {
        match self {
            Ok(o) => o,
            Err(e) => scope.terminate(Err(e)).await,
        }
    }
}