Struct actix::sync::SyncArbiter

pub struct SyncArbiter<A> where
    A: Actor<Context = SyncContext<A>>,  { /* fields omitted */ }

Sync arbiter

Methods

impl<A> SyncArbiter<A> where     A: Actor<Context = SyncContext<A>>,

pub fn start<F>(threads: usize, factory: F) -> Addr<A> where     F: Fn() -> A + Send + Sync + 'static,

Start new sync arbiter with specified number of worker threads. Returns address of the started actor.

Trait Implementations

impl<A> Actor for SyncArbiter<A> where     A: Actor<Context = SyncContext<A>>,

type Context = Context<Self>

Actor execution context type

fn started(&mut self, ctx: &mut Self::Context)

Called when an actor gets polled the first time.

fn stopping(&mut self, ctx: &mut Self::Context) -> Running

Called after an actor is in Actor::Stopping state.

fn stopped(&mut self, ctx: &mut Self::Context)

Called after an actor is stopped.

fn start(self) -> Addr<Self> where     Self: Actor<Context = Context<Self>>,

Start a new asynchronous actor, returning its address.

fn start_default() -> Addr<Self> where     Self: Actor<Context = Context<Self>> + Default,

Construct and start a new asynchronous actor, returning its address.

fn create<F>(f: F) -> Addr<Self> where     Self: Actor<Context = Context<Self>>,     F: FnOnce(&mut Context<Self>) -> Self + 'static,

Start a new asynchronous actor given a Context.