Struct xactor::Context

pub struct Context<A> { /* fields omitted */ }

An actor execution context.

Implementations

impl<A> Context<A>

pub fn address(&self) -> Addr<A>

Returns the address of the actor.

pub fn actor_id(&self) -> ActorId

Returns the id of the actor.

pub fn stop(&self, err: Option<Error>)

Stop the actor.

pub fn abort_intervals(&mut self)

pub fn abort_streams(&mut self)

pub fn add_stream<S>(&mut self, stream: S) where
    S: Stream + Unpin + Send + 'static,
    S::Item: 'static + Send,
    A: StreamHandler<S::Item>, 

Create a stream handler for the actor.

Examples

use xactor::*;
use futures::stream;
use std::time::Duration;

#[message(result = "i32")]
struct GetSum;

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

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

    async fn started(&mut self, _ctx: &mut Context<Self>) {
        println!("stream started");
    }

    async fn finished(&mut self, _ctx: &mut Context<Self>) {
        println!("stream finished");
    }
}

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

#[async_trait::async_trait]
impl Actor for MyActor {
    async fn started(&mut self, ctx: &mut Context<Self>) -> Result<()> {
        let values = (0..100).collect::<Vec<_>>();
        ctx.add_stream(stream::iter(values));
        Ok(())
    }
}

#[xactor::main]
async fn main() -> Result<()> {
    let mut addr = MyActor::start_default().await?;
    sleep(Duration::from_secs(1)).await; // Wait for the stream to complete
    let res = addr.call(GetSum).await?;
    assert_eq!(res, (0..100).sum::<i32>());
    Ok(())
}

pub fn send_later<T>(&mut self, msg: T, after: Duration) where
    A: Handler<T>,
    T: Message<Result = ()>, 

Sends the message msg to self after a specified period of time.

We use Sender instead of Addr so that the interval doesn't keep reference to address and prevent the actor from being dropped and stopped

pub fn send_interval_with<T, F>(&mut self, f: F, dur: Duration) where
    A: Handler<T>,
    F: Fn() -> T + Sync + Send + 'static,
    T: Message<Result = ()>, 

Sends the message to self, at a specified fixed interval. The message is created each time using a closure f.

pub fn send_interval<T>(&mut self, msg: T, dur: Duration) where
    A: Handler<T>,
    T: Message<Result = ()> + Clone + Sync, 

Sends the message msg to self, at a specified fixed interval.

pub async fn subscribe<T: Message<Result = ()>>(&self) -> Result<()> where
    A: Handler<T>, 

Subscribes to a message of a specified type.

pub async fn unsubscribe<T: Message<Result = ()>>(&self) -> Result<()>

Unsubscribe to a message of a specified type.