Struct actix::Arbiter
[−]
[src]
pub struct Arbiter { /* fields omitted */ }
Methods
impl Arbiter[src]
fn new() -> Arbiter[src]
fn get() -> Address<Arbiter>[src]
Return current arbiter address
fn handle() -> &'static Handle[src]
fn start<F, T>(&self, f: F) -> Receiver<SyncAddress<T>> where
T: Actor,
F: 'static + Send + FnOnce(&mut Context<T>) -> T, [src]
T: Actor,
F: 'static + Send + FnOnce(&mut Context<T>) -> T,
Trait Implementations
impl Actor for Arbiter[src]
fn start(&mut self, ctx: &mut Context<Self>)[src]
Method is called when actor get polled first time.
fn finished(&mut self, ctx: &mut Context<Self>)[src]
Method is called when context's stream finishes. By default returns ActorStatus::Done. Read more
impl Clone for Arbiter[src]
fn clone(&self) -> Self[src]
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)1.0.0[src]
Performs copy-assignment from source. Read more
impl MessageHandler<StopArbiter> for Arbiter[src]
type Item = ()
The type of value that this message will resolved with if it is successful.
type Error = ()
The type of error that this message will resolve with if it fails in a normal fashion.
type InputError = ()
If message handler is used for handling messages from Future or Stream, then InputError type has to be set to correspondent Error Read more
fn handle(
&mut self,
msg: StopArbiter,
_: &mut Context<Self>
) -> MessageFuture<Self, StopArbiter>[src]
&mut self,
msg: StopArbiter,
_: &mut Context<Self>
) -> MessageFuture<Self, StopArbiter>
Method is called for every message received by this Actor
fn error(&mut self, err: Self::InputError, ctx: &mut Context<Self>)[src]
Method is called on error.
impl MessageHandler<ArbiterAddress> for Arbiter[src]
type Item = SyncAddress<Arbiter>
The type of value that this message will resolved with if it is successful.
type Error = ()
The type of error that this message will resolve with if it fails in a normal fashion.
type InputError = ()
If message handler is used for handling messages from Future or Stream, then InputError type has to be set to correspondent Error Read more
fn handle(
&mut self,
_: ArbiterAddress,
ctx: &mut Context<Self>
) -> MessageFuture<Self, ArbiterAddress>[src]
&mut self,
_: ArbiterAddress,
ctx: &mut Context<Self>
) -> MessageFuture<Self, ArbiterAddress>
Method is called for every message received by this Actor
fn error(&mut self, err: Self::InputError, ctx: &mut Context<Self>)[src]
Method is called on error.