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

use std::pin::Pin;

use futures::Future;

use crate::body::Body;

pub struct ScopeBody<'env, R: 'env>
where
    R: Send,
{
    body: Body<'env, 'env, R>,
}

impl<'env, R> ScopeBody<'env, R>
where
    R: Send,
{
    pub(crate) fn new(body: Body<'env, 'env, R>) -> Self {
        Self { body }
    }
}

impl<'env, R> Future for ScopeBody<'env, R>
where
    R: Send,
{
    type Output = R;

    fn poll(
        self: std::pin::Pin<&mut Self>,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll<Self::Output> {
        Pin::new(&mut self.get_mut().body).poll(cx)
    }
}

impl<R: Send> Unpin for ScopeBody<'_, R> {}