par 0.3.10

Session types, as an implementation of linear logic with MIX
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

//! Asynchronous forking functions for different `async` runtimes.

#[cfg(feature = "runtime-tokio")]
pub mod tokio {
    use crate::Session;
    use futures::Future;

    pub fn fork<S: Session, F>(f: impl FnOnce(S::Dual) -> F) -> S
    where
        F: Future<Output = ()> + Send + 'static,
    {
        S::fork_sync(|session| drop(tokio::spawn(f(session))))
    }
}

pub mod spawn {
    use crate::Session;
    use futures::{task::SpawnExt, Future};

    pub trait Fork {
        fn fork<S: Session, F>(&self, f: impl FnOnce(S::Dual) -> F) -> S
        where
            F: Future<Output = ()> + Send + 'static;
    }

    impl<Spawn: futures::task::Spawn> Fork for Spawn {
        fn fork<S: Session, F>(&self, f: impl FnOnce(S::Dual) -> F) -> S
        where
            F: Future<Output = ()> + Send + 'static,
        {
            S::fork_sync(|session| self.spawn(f(session)).ok().expect("spawn failed"))
        }
    }
}

pub mod local_spawn {
    use crate::Session;
    use futures::{task::LocalSpawnExt, Future};

    pub trait Fork {
        fn fork<S: Session, F>(&self, f: impl FnOnce(S::Dual) -> F) -> S
        where
            F: Future<Output = ()> + Send + 'static;
    }

    impl<Spawn: futures::task::LocalSpawn> Fork for Spawn {
        fn fork<S: Session, F>(&self, f: impl FnOnce(S::Dual) -> F) -> S
        where
            F: futures::Future<Output = ()> + Send + 'static,
        {
            S::fork_sync(|session| self.spawn_local(f(session)).ok().expect("spawn failed"))
        }
    }
}