Struct chekov::SubscriberManager
source · pub struct SubscriberManager<A: Application> { /* private fields */ }
Expand description
Deal with Application subscriptions
Trait Implementations§
source§impl<A: Application> Actor for SubscriberManager<A>
impl<A: Application> Actor for SubscriberManager<A>
§type Context = Context<SubscriberManager<A>>
type Context = Context<SubscriberManager<A>>
Actor execution context type
source§fn started(&mut self, _ctx: &mut Self::Context)
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
fn stopping(&mut self, ctx: &mut Self::Context) -> Running
Called after an actor is in
Actor::Stopping
state. Read more§fn start(self) -> Addr<Self>where
Self: Actor<Context = Context<Self>>,
fn start(self) -> Addr<Self>where Self: Actor<Context = Context<Self>>,
Start a new asynchronous actor, returning its address. Read more
§fn start_default() -> Addr<Self>where
Self: Actor<Context = Context<Self>> + Default,
fn start_default() -> Addr<Self>where Self: Actor<Context = Context<Self>> + Default,
Construct and start a new asynchronous actor, returning its
address. Read more
§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,
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.
source§impl<A: Application> Default for SubscriberManager<A>
impl<A: Application> Default for SubscriberManager<A>
source§impl<A: Application> Supervised for SubscriberManager<A>
impl<A: Application> Supervised for SubscriberManager<A>
§fn restarting(&mut self, ctx: &mut Self::Context)
fn restarting(&mut self, ctx: &mut Self::Context)
Called when the supervisor restarts a failed actor.
source§impl<A: Application> SystemService for SubscriberManager<A>
impl<A: Application> SystemService for SubscriberManager<A>
§fn start_service(wrk: &ArbiterHandle) -> Addr<Self>
fn start_service(wrk: &ArbiterHandle) -> Addr<Self>
Construct and start system service
§fn service_started(&mut self, ctx: &mut Context<Self>)
fn service_started(&mut self, ctx: &mut Context<Self>)
Method is called during service initialization.
§fn from_registry() -> Addr<Self>
fn from_registry() -> Addr<Self>
Get actor’s address from system registry
Auto Trait Implementations§
impl<A> !RefUnwindSafe for SubscriberManager<A>
impl<A> Send for SubscriberManager<A>
impl<A> Sync for SubscriberManager<A>
impl<A> Unpin for SubscriberManager<A>
impl<A> !UnwindSafe for SubscriberManager<A>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more