troupe 0.1.0

Library for modelling Rust applications with actors
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

//! The compatability layer between async runtimes as well as native vs WASM targets.

use std::fmt::Debug;

use futures::{stream::FusedStream, Future, Stream};

#[cfg(not(target_family = "wasm"))]
mod native;
#[cfg(not(target_family = "wasm"))]
pub use native::*;

#[cfg(target_family = "wasm")]
mod wasm;
#[cfg(target_family = "wasm")]
pub use wasm::*;

/// A trait to abstract over if a future can be processed in a seperate async process.
pub trait SendableFuture: Sendable + Future {}

impl<T> SendableFuture for T where T: Sendable + Future {}

/// A trait to abstract over if a stream can be managed by the [`Scheduler`](crate::Scheduler).
pub trait SendableStream: Sendable + Unpin + Stream {}

impl<T> SendableStream for T where T: Sendable + Unpin + Stream {}

/// A trait to abstract over if a fused stream can be managed by the
/// [`Scheduler`](crate::Scheduler).
pub trait SendableFusedStream: SendableStream + FusedStream {}

impl<T> SendableFusedStream for T where T: SendableStream + FusedStream {}

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

#[cfg(test)]
mod test {
    // Import tests
    #[allow(unused_imports)]
    use super::{sleep_for, sleep_until, spawn_task, Sendable};

    // Impl trait tests
}