Struct actix::registry::SystemRegistry [−][src]
System wide actors registry
System registry serves same purpose as Registry, except it is shared across all arbiters.
Examples
use actix::prelude::*; #[derive(Message)] #[rtype(result = "()")] struct Ping; #[derive(Default)] struct MyActor1; impl Actor for MyActor1 { type Context = Context<Self>; } impl actix::Supervised for MyActor1 {} impl SystemService for MyActor1 { fn service_started(&mut self, ctx: &mut Context<Self>) { println!("Service started"); } } impl Handler<Ping> for MyActor1 { type Result = (); fn handle(&mut self, _: Ping, ctx: &mut Context<Self>) { println!("ping"); } } struct MyActor2; impl Actor for MyActor2 { type Context = Context<Self>; fn started(&mut self, _: &mut Context<Self>) { let act = MyActor1::from_registry(); act.do_send(Ping); } } fn main() { // initialize system let code = System::new().block_on(async { // Start MyActor2 let addr = MyActor2.start(); }); }
Implementations
impl SystemRegistry
[src]
pub fn get<A: SystemService + Actor<Context = Context<A>>>(&mut self) -> Addr<A>
[src]
Return address of the service. If service actor is not running it get started in the system.
pub fn query<A: SystemService + Actor<Context = Context<A>>>(
&self
) -> Option<Addr<A>>
[src]
&self
) -> Option<Addr<A>>
Check if actor is in registry, if so, return its address
pub fn set<A: SystemService + Actor<Context = Context<A>>>(addr: Addr<A>)
[src]
Add new actor to the registry by address, panic if actor is already running
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for SystemRegistry
impl Send for SystemRegistry
impl !Sync for SystemRegistry
impl Unpin for SystemRegistry
impl !UnwindSafe for SystemRegistry
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut Tⓘ
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,