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
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150

//! # Actix is a rust actor framework.
//!
//! [Actors](https://actix.github.io/actix/actix/trait.Actor.html) are objects
//! which encapsulate state and behavior, they communicate exclusively
//! by exchanging messages. Actix actors are implemented on top of [Tokio](https://tokio.rs).
//! Mutiple actors could run in same thread. Actors could run in multiple threads
//! with support of [`Arbiter`](https://actix.github.io/actix/actix/struct.Arbiter.html).
//! Actors exchange typed messages.
//!
//! ## Features
//!
//! * Async/Sync actors.
//! * Actor communication in a local/thread context.
//! * Using Futures for asynchronous message handling.
//! * HTTP1/HTTP2 support ([actix-web](https://github.com/actix/actix-web))
//! * Actor supervision.
//! * Typed messages (No `Any` type). Generic messages are allowed.
//! * Minimum supported Rust version: 1.20 or later

#[macro_use]
extern crate log;
extern crate libc;
extern crate uuid;
extern crate smallvec;
extern crate crossbeam;
#[macro_use]
extern crate bitflags;
#[macro_use]
extern crate futures;
extern crate tokio_io;
extern crate tokio_core;
extern crate tokio_signal;

#[cfg_attr(feature="cargo-clippy", allow(useless_attribute))]
#[allow(unused_imports)]
#[macro_use]
extern crate actix_derive;

#[cfg(test)]
extern crate bytes;

#[doc(hidden)]
pub use actix_derive::*;

mod actor;
mod arbiter;
mod address;
mod context;
mod contextimpl;
mod contextcells;
mod contextitems;
mod envelope;
mod framed;
mod handler;
pub mod queue;
mod message;
mod registry;
mod system;
mod supervisor;
mod utils;

pub mod fut;
pub mod actors;
pub mod msgs;
pub mod sync;

#[doc(hidden)]
pub mod constants;

pub use fut::{ActorFuture, ActorStream, WrapFuture, WrapStream, FinishStream};
pub use actor::{Actor, ActorState, FramedActor, Supervised,
                ActorContext, AsyncContext, SpawnHandle};
pub use handler::{Handler, ResponseType, MessageResult, ResponseFuture};
pub use arbiter::Arbiter;
pub use address::{Address, SyncAddress, Subscriber, ActorAddress};
pub use context::{Context, ContextFutureSpawner};
pub use envelope::ToEnvelope;
pub use framed::FramedContext;
pub use message::{Request, Response};
pub use sync::{SyncContext, SyncArbiter};
pub use registry::{Registry, SystemRegistry, ArbiterService, SystemService};
pub use system::{System, SystemRunner};
pub use utils::Condition;
pub use supervisor::Supervisor;

pub mod prelude {
//! The `actix` prelude
//!
//! The purpose of this module is to alleviate imports of many common actix traits
//! by adding a glob import to the top of actix heavy modules:
//!
//! ```
//! # #![allow(unused_imports)]
//! use actix::prelude::*;
//! ```

#[doc(hidden)]
pub use actix_derive::*;

pub use fut::{ActorFuture, ActorStream, WrapFuture, WrapStream};
pub use actor::{Actor, ActorContext, AsyncContext, FramedActor};
pub use arbiter::Arbiter;
pub use address::{Address, SyncAddress};
pub use framed::FramedContext;
pub use message::Response;
pub use handler::{Handler, ResponseType, MessageResult, ResponseFuture};
pub use context::{Context, ContextFutureSpawner};
pub use system::System;
pub use sync::{SyncContext, SyncArbiter};

pub mod actix {
    pub use msgs;
    pub use fut::{self, ActorFuture, ActorStream, WrapFuture, WrapStream};
    pub use actor::{Actor, ActorState, FramedActor, Supervised,
                    ActorContext, AsyncContext, SpawnHandle};
    pub use handler::{Handler, ResponseType, MessageResult, ResponseFuture};
    pub use arbiter::Arbiter;
    pub use address::{Address, SyncAddress, Subscriber, ActorAddress};
    pub use context::{Context, ContextFutureSpawner};
    pub use framed::FramedContext;
    pub use message::{Request, Response};
    pub use system::System;
    pub use sync::{SyncContext, SyncArbiter};
    pub use registry::{ArbiterService, SystemService};
    pub use utils::Condition;
}}


pub mod dev {
//! The `actix` prelude for library developers
//!
//! The purpose of this module is to alleviate imports of many common actix traits
//! by adding a glob import to the top of actix heavy modules:
//!
//! ```
//! # #![allow(unused_imports)]
//! use actix::dev::*;
//! ```

    pub use prelude::*;
    pub use prelude::actix::*;

    pub use queue;
    pub use address::{ActorAddress};
    pub use context::AsyncContextApi;
    pub use contextimpl::ContextImpl;
    pub use contextcells::{ContextProtocol, ContextCellResult,
                           ActorAddressCell, ActorItemsCell, ActorWaitCell};
    pub use envelope::{Envelope, ToEnvelope, RemoteEnvelope};
}