tokactor 2.1.0

A actor model framework wrapped around tokio
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

#![recursion_limit = "512"]

mod actor;
mod address;
mod anonymous;
mod context;
mod envelope;
mod executor;
mod generic;
mod io;
mod message;
mod single;
mod utils;
mod world;

pub use crate::actor::{Actor, Ask, AsyncAsk, Handler, Scheduler};
pub use crate::address::{ActorRef, AnonymousRef, AskError, IntoFutureError, SendError};
pub use crate::context::{ActorContext, Ctx};
pub use crate::message::{AskResult, DeadActorResult, Message};
pub use crate::world::{builder::WorldBuilder, messages::TcpRequest, World, WorldResult};

pub mod util {
    pub mod read {
        pub use crate::io::read::Read;
    }
    pub mod builder {
        pub use crate::single::{ActorAskRef, ActorAsyncAskRef, ActorSendRef, CtxBuilder};
    }
    pub use crate::utils::router::Router;
    pub mod io {
        pub use crate::io::{
            Component, ComponentReader, DataFrame, DataFrameReceiver, Reader, Writer,
        };
    }
    pub mod fs {
        pub use crate::io::fs::FsActor;
    }
    pub use crate::utils::workflow::Workflow;
}