pub struct Arbiter { /* private fields */ }
Expand description
Event loop controller
Arbiter controls event loop in its thread. Each arbiter runs in separate
thread. Arbiter provides several api for event loop access. Each arbiter
can belongs to specific System
actor.
By default, a panic in an Arbiter does not stop the rest of the System,
unless the panic is in the System actor. Users of Arbiter can opt into
shutting down the system on panic by using Arbiter::builder()
and enabling
stop_system_on_panic
.
Implementations
sourceimpl Arbiter
impl Arbiter
sourcepub fn builder() -> Builder
pub fn builder() -> Builder
Spawn new thread and run event loop in spawned thread. Returns address of newly created arbiter. Does not stop the system on panic.
sourcepub fn new<T>(name: T) -> Addr<Arbiter>where
T: Into<String>,
pub fn new<T>(name: T) -> Addr<Arbiter>where
T: Into<String>,
Spawn new thread and run event loop in spawned thread. Returns address of newly created arbiter. Does not stop the system on panic.
sourcepub fn spawn<F>(future: F)where
F: 'static + Future<Item = (), Error = ()>,
pub fn spawn<F>(future: F)where
F: 'static + Future<Item = (), Error = ()>,
Executes a future on the current thread.
Trait Implementations
sourceimpl Actor for Arbiter
impl Actor for Arbiter
sourcefn started(&mut self, ctx: &mut Self::Context)
fn started(&mut self, ctx: &mut Self::Context)
Method is called when actor get polled first time.
sourcefn stopping(&mut self, ctx: &mut Self::Context) -> Running
fn stopping(&mut self, ctx: &mut Self::Context) -> Running
Method is called after an actor is in
Actor::Stopping
state. There
could be several reasons for stopping. Context::stop
get called
by the actor itself. All addresses to current actor get dropped and
no more evented objects left in the context. Read moresourcefn stopped(&mut self, ctx: &mut Self::Context)
fn stopped(&mut self, ctx: &mut Self::Context)
Method is called after an actor is stopped, it can be used to perform
any needed cleanup work or spawning more actors. This is final state,
after this call actor get dropped. Read more
Auto Trait Implementations
impl !RefUnwindSafe for Arbiter
impl Send for Arbiter
impl Sync for Arbiter
impl Unpin for Arbiter
impl !UnwindSafe for Arbiter
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more