act-zero 0.4.0

Ergonomic actor system
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

//! Dummy runtime implementation which panics on use.
//!
//! This is used when no default runtime is enabled, and allows
//! libraries to be built against this crate that *use* features
//! requiring a runtime, but remaining runtime-agnostic.
//!
//! Binary crates should enable a specific default runtime, or
//! enable the `default-disabled` feature to ensure this runtime
//! is not used.

use std::time::Instant;

use futures::future::Pending;
use futures::task::{Spawn, SpawnError};

use crate::{timer, Actor, Addr};

/// Type representing the dummy runtime.
#[derive(Debug, Copy, Clone, Default)]
pub struct Runtime;

/// Alias for a dummy timer. This type can be default-constructed.
/// Will always panic on use.
pub type Timer = timer::Timer<Runtime>;

/// Spawn an actor onto the dummy runtime.
/// Will always panic.
pub fn spawn_actor<T: Actor>(actor: T) -> Addr<T> {
    Addr::new(&Runtime, actor).unwrap()
}

impl Spawn for Runtime {
    fn spawn_obj(
        &self,
        _future: futures::future::FutureObj<'static, ()>,
    ) -> Result<(), SpawnError> {
        panic!("No default runtime selected")
    }
}

impl timer::SupportsTimers for Runtime {
    type Delay = Pending<()>;
    fn delay(&self, _deadline: Instant) -> Self::Delay {
        panic!("No default runtime selected")
    }
}