Struct xactor::Broker

pub struct Broker<T: Message<Result = ()>> { /* fields omitted */ }

Message broker is used to support publishing and subscribing to messages.

Examples

use xactor::*;
use std::time::Duration;
use async_std::task;

#[message]
#[derive(Clone)]
struct MyMsg(&'static str);

#[message(result = "String")]
struct GetValue;

#[derive(Default)]
struct MyActor(String);

#[async_trait::async_trait]
impl Actor for MyActor {
    async fn started(&mut self, ctx: &Context<Self>)  {
        ctx.subscribe::<MyMsg>().await;
    }
}

#[async_trait::async_trait]
impl Handler<MyMsg> for MyActor {
    async fn handle(&mut self, _ctx: &Context<Self>, msg: MyMsg) {
        self.0 += msg.0;
    }
}

#[async_trait::async_trait]
impl Handler<GetValue> for MyActor {
    async fn handle(&mut self, _ctx: &Context<Self>, _msg: GetValue) -> String {
        self.0.clone()
    }
}

#[async_std::main]
async fn main() -> Result<()> {
    let mut addr1 = MyActor::start_default().await;
    let mut addr2 = MyActor::start_default().await;

    Broker::from_registry().await.publish(MyMsg("a"));
    Broker::from_registry().await.publish(MyMsg("b"));

    task::sleep(Duration::from_secs(1)).await; // Wait for the messages

    assert_eq!(addr1.call(GetValue).await?, "ab");
    assert_eq!(addr2.call(GetValue).await?, "ab");
    Ok(())
}

Trait Implementations

impl<T: Message<Result = ()>> Actor for Broker<T>

fn started<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 Context<Self>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Called when the actor is first started.

fn stopped<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 Context<Self>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Called after an actor is stopped.

fn start_default<'async_trait>(
) -> Pin<Box<dyn Future<Output = Addr<Self>> + Send + 'async_trait>> where
    Self: Default,
    Self: 'async_trait, 

Construct and start a new actor, returning its address.

fn start<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Addr<Self>> + Send + 'async_trait>> where
    Self: 'async_trait, 

Start a new actor, returning its address.

impl<T: Message<Result = ()>> Default for Broker<T>

fn default() -> Self

Returns the "default value" for a type.

impl<T: Message<Result = ()>> Service for Broker<T>

fn from_registry<'async_trait>(
) -> Pin<Box<dyn Future<Output = Addr<Self>> + Send + 'async_trait>> where
    Self: Send + 'async_trait,