remoc 0.18.3

🦑 Remote multiplexed objects, channels, observable collections and RPC making remote interactions seamless. Provides multiple remote channels and RPC over TCP, TLS or any other transport.
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

//! Native async executive using Tokio.

pub mod runtime {
    pub use tokio::runtime::Handle;
}

pub mod task {
    use std::future::Future;

    pub use tokio::task::{JoinError, JoinHandle, spawn, spawn_blocking};

    /// Runs a future to completion.
    #[track_caller]
    pub fn block_on<F: Future>(future: F) -> F::Output {
        let rt = tokio::runtime::Builder::new_current_thread().build().unwrap();
        rt.block_on(future)
    }
}

pub mod time {
    pub use tokio::time::{Sleep, Timeout, sleep, timeout};

    pub mod error {
        pub use tokio::time::error::Elapsed;
    }
}