atomr-core 0.1.0

Actors, supervision, dispatch, mailboxes, scheduler, FSM, event stream, and coordinated shutdown — the core of the atomr actor runtime.
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
55
56
57

//! # atomr-core
//!
//! Idiomatic Rust port of `akka.net/src/core/Akka`.
//!
//! Public modules mirror the upstream folder layout 1:1 to make tracking
//! upstream changes tractable. See `PORTING.md` at the workspace root.
//!
//! ## Quick start
//!
//! ```no_run
//! use atomr_core::prelude::*;
//!
//! #[derive(Default)]
//! struct Echo;
//!
//! #[async_trait::async_trait]
//! impl Actor for Echo {
//!     type Msg = String;
//!     async fn handle(&mut self, _ctx: &mut Context<Self>, msg: String) {
//!         println!("echo: {msg}");
//!     }
//! }
//!
//! # async fn run() -> Result<(), Box<dyn std::error::Error>> {
//! let sys = ActorSystem::create("S", atomr_config::Config::reference()).await?;
//! let echo = sys.actor_of(Props::create(Echo::default), "echo")?;
//! echo.tell("hi".to_string());
//! sys.terminate().await;
//! # Ok(()) }
//! ```

#![forbid(unsafe_code)]
#![deny(rust_2018_idioms)]

pub mod actor;
pub mod dispatch;
#[macro_use]
mod fsm_macro;
pub mod event;
pub mod io;
pub mod pattern;
pub mod routing;
pub mod serialization;
pub mod supervision;
pub mod util;

pub mod prelude {
    pub use crate::actor::{
        Actor, ActorPath, ActorRef, ActorSystem, Address, Context, Props, UntypedActorRef,
    };
    pub use crate::pattern::{ask, pipe_to};
    pub use crate::supervision::{
        Directive, OneForOneStrategy, SupervisionError, SupervisorOf, SupervisorStrategy,
    };
    pub use async_trait::async_trait;
    pub use atomr_config::Config;
}