Struct actix_broker::Broker

pub struct Broker<T> { /* fields omitted */ }

Implementations

impl Broker<SystemBroker>

The system service actor that keeps track of subscriptions and routes messages to them.

pub fn issue_async<M: BrokerMsg>(msg: M)

Send messages asynchronously via the broker. It can be called from with actors with a SyncContext, or where you don’t have access to self. e.g. From within a HttpHandler from actix-web.

impl Broker<ArbiterBroker>

The system service actor that keeps track of subscriptions and routes messages to them.

pub fn issue_async<M: BrokerMsg>(msg: M)

Send messages asynchronously via the broker. It can be called from with actors with a SyncContext, or where you don’t have access to self. e.g. From within a HttpHandler from actix-web.

Trait Implementations

impl<T: 'static + Unpin> Actor for Broker<T>

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 start_in_arbiter<F>(wrk: &ArbiterHandle, f: F) -> Addr<Self> where
    Self: Actor<Context = Context<Self>>,
    F: FnOnce(&mut Context<Self>) -> Self + Send + 'static, 

Start new actor in arbiter’s thread.

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

Start a new asynchronous actor given a Context.

impl ArbiterService for Broker<ArbiterBroker>

fn start_service() -> Addr<Self>

Construct and start arbiter service

fn service_started(&mut self, ctx: &mut Context<Self>)

Method is called during service initialization.

fn from_registry() -> Addr<Self>

Get actor’s address from arbiter registry

impl<T: Default> Default for Broker<T>

fn default() -> Broker<T>

Returns the “default value” for a type.

impl Supervised for Broker<SystemBroker>

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

Called when the supervisor restarts a failed actor.

impl Supervised for Broker<ArbiterBroker>

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

Called when the supervisor restarts a failed actor.

impl SystemService for Broker<SystemBroker>

fn start_service(wrk: &ArbiterHandle) -> Addr<Self>

Construct and start system service

fn service_started(&mut self, ctx: &mut Context<Self>)

Method is called during service initialization.

fn from_registry() -> Addr<Self>

Get actor’s address from system registry