Struct Context

Source

pub struct Context<ActorId = DefaultActorId> { /* private fields */ }

Implementations§

Source §

impl<ActorId> Context<ActorId>

Source

pub fn new() -> Self

Examples found in repository ?

examples/simple.rs (line 33)

32async fn main() {
33    let ctx = Context::new();
34    MyActor::run(ctx.clone(), 42);
35
36    let sender = ctx.sender::<Value>();
37    sender.send(Value(11)).await.ok();
38    sender.send(Value(22)).await.ok();
39}

More examples

Hide additional examples

examples/lifecycle.rs (line 33)

32async fn main() {
33    let ctx = Context::new();
34    MyActor::run(ctx.clone(), 42);
35
36    let sender = ctx.sender::<Value>();
37    sender.send(Value(11)).await.ok();
38    sender.send(Value(22)).await.ok();
39
40    ctx.shutdown().await;
41}

examples/dynamic.rs (line 40)

39async fn main() {
40    let ctx = Context::new();
41
42    MyActor::run(ctx.clone(), "actor 1", 1);
43    let actor_2_task = MyActor::run(ctx.clone(), "actor 2", 2);
44
45    let sender_1 = ctx.actor_sender::<Value>("actor 1");
46    sender_1.send(Value(11)).await.ok();
47    sender_1.send(Value(12)).await.ok();
48
49    let sender_2 = ctx.actor_sender::<Value>("actor 2");
50    sender_2.send(Value(21)).await.ok();
51    sender_2.send(Value(22)).await.ok();
52
53    sender_2.send(Value(0)).await.ok();
54    ctx.join(&actor_2_task).await.ok();
55
56    MyActor::run(ctx.clone(), "actor 2", 2);
57
58    let sender_2 = ctx.actor_sender::<Value>("actor 2");
59    sender_2.send(Value(23)).await.ok();
60
61    ctx.shutdown().await;
62}

Source

pub fn from_system(system: System<ActorId>) -> Self

Source

pub fn spawn<T>(&self, future: T) -> TaskId
where T: Future<Output = ()> + Send + 'static,

Examples found in repository ?

examples/dynamic.rs (lines 19-29)

14    fn run(ctx: Context, actor_id: &'static str, value: u32) -> TaskId {
15        let mut value_in = ctx.actor_receiver::<Value>(actor_id);
16        let mut actor = MyActor { value };
17
18        println!("run the {actor_id}");
19        ctx.clone().spawn(async move {
20            truba::event_loop!(ctx, {
21                Some(msg) = value_in.recv() => {
22                    actor.handle_value(msg);
23                    if actor.value == 0 {
24                        break;
25                    }
26                },
27            });
28            println!("stop the {actor_id}");
29        })
30    }

Source

pub fn extract_channel<M: Message>(&self) -> Option<M::Channel>

Source

pub fn get_sender<M: Message>(&self) -> Option<<M::Channel as Channel>::Sender>

Source

pub fn sender_of_custom_channel<M: Message>( &self, constructor: impl FnOnce() -> M::Channel, ) -> <M::Channel as Channel>::Sender

Source

pub fn receiver_of_custom_channel<M: Message>( &self, constructor: impl FnOnce() -> M::Channel, ) -> <M::Channel as Channel>::Receiver

Source

pub fn sender<M: Message>(&self) -> <M::Channel as Channel>::Sender

Examples found in repository ?

examples/simple.rs (line 36)

32async fn main() {
33    let ctx = Context::new();
34    MyActor::run(ctx.clone(), 42);
35
36    let sender = ctx.sender::<Value>();
37    sender.send(Value(11)).await.ok();
38    sender.send(Value(22)).await.ok();
39}

More examples

Hide additional examples

examples/lifecycle.rs (line 36)

32async fn main() {
33    let ctx = Context::new();
34    MyActor::run(ctx.clone(), 42);
35
36    let sender = ctx.sender::<Value>();
37    sender.send(Value(11)).await.ok();
38    sender.send(Value(22)).await.ok();
39
40    ctx.shutdown().await;
41}

Source

pub fn receiver<M: Message>(&self) -> <M::Channel as Channel>::Receiver

Examples found in repository ?

examples/lifecycle.rs (line 15)

14    fn run(ctx: Context, value: u32) {
15        let mut value_in = ctx.receiver::<Value>();
16        let mut actor = MyActor { value };
17
18        truba::spawn_event_loop!(ctx, {
19            Some(msg) = value_in.recv() => {
20                actor.handle_value(msg);
21            },
22        });
23    }

More examples

Hide additional examples

examples/simple.rs (line 15)

14    fn run(ctx: Context, value: u32) {
15        let mut value_in = ctx.receiver::<Value>();
16        let mut actor = MyActor { value };
17
18        truba::spawn_min_event_loop!(ctx, {
19            Some(msg) = value_in.recv() => {
20                actor.handle_value(msg);
21            },
22        });
23    }

Source

pub fn is_channel_closed<M: Message>(&self) -> Option<bool>

Source

pub fn system(&self) -> MutexGuard<'_, System<ActorId>>

Source

pub async fn shutdown(&self)

Examples found in repository ?

examples/lifecycle.rs (line 40)

32async fn main() {
33    let ctx = Context::new();
34    MyActor::run(ctx.clone(), 42);
35
36    let sender = ctx.sender::<Value>();
37    sender.send(Value(11)).await.ok();
38    sender.send(Value(22)).await.ok();
39
40    ctx.shutdown().await;
41}

More examples

Hide additional examples

examples/dynamic.rs (line 61)

39async fn main() {
40    let ctx = Context::new();
41
42    MyActor::run(ctx.clone(), "actor 1", 1);
43    let actor_2_task = MyActor::run(ctx.clone(), "actor 2", 2);
44
45    let sender_1 = ctx.actor_sender::<Value>("actor 1");
46    sender_1.send(Value(11)).await.ok();
47    sender_1.send(Value(12)).await.ok();
48
49    let sender_2 = ctx.actor_sender::<Value>("actor 2");
50    sender_2.send(Value(21)).await.ok();
51    sender_2.send(Value(22)).await.ok();
52
53    sender_2.send(Value(0)).await.ok();
54    ctx.join(&actor_2_task).await.ok();
55
56    MyActor::run(ctx.clone(), "actor 2", 2);
57
58    let sender_2 = ctx.actor_sender::<Value>("actor 2");
59    sender_2.send(Value(23)).await.ok();
60
61    ctx.shutdown().await;
62}

Source

pub async fn join_all(&self)

Source

pub async fn join(&self, id: &TaskId) -> Result<(), JoinError>

Examples found in repository ?

examples/dynamic.rs (line 54)

39async fn main() {
40    let ctx = Context::new();
41
42    MyActor::run(ctx.clone(), "actor 1", 1);
43    let actor_2_task = MyActor::run(ctx.clone(), "actor 2", 2);
44
45    let sender_1 = ctx.actor_sender::<Value>("actor 1");
46    sender_1.send(Value(11)).await.ok();
47    sender_1.send(Value(12)).await.ok();
48
49    let sender_2 = ctx.actor_sender::<Value>("actor 2");
50    sender_2.send(Value(21)).await.ok();
51    sender_2.send(Value(22)).await.ok();
52
53    sender_2.send(Value(0)).await.ok();
54    ctx.join(&actor_2_task).await.ok();
55
56    MyActor::run(ctx.clone(), "actor 2", 2);
57
58    let sender_2 = ctx.actor_sender::<Value>("actor 2");
59    sender_2.send(Value(23)).await.ok();
60
61    ctx.shutdown().await;
62}

Source

pub fn handles(&self) -> &TaskHandles

Source §

impl<ActorId: Eq + Hash> Context<ActorId>

Source

pub fn extract_actor_channel<M: Message>( &self, actor_id: &ActorId, ) -> Option<M::Channel>

Source

pub fn get_actor_sender<M: Message>( &self, actor_id: &ActorId, ) -> Option<<M::Channel as Channel>::Sender>

Source

pub fn actor_sender_of_custom_channel<M: Message>( &self, actor_id: ActorId, constructor: impl FnOnce() -> M::Channel, ) -> <M::Channel as Channel>::Sender

Source

pub fn actor_receiver_of_custom_channel<M: Message>( &self, actor_id: ActorId, constructor: impl FnOnce() -> M::Channel, ) -> <M::Channel as Channel>::Receiver

Source §

impl<ActorId: Eq + Hash + Display> Context<ActorId>

Source

pub fn actor_sender<M: Message>( &self, actor_id: impl Into<ActorId>, ) -> <M::Channel as Channel>::Sender

Examples found in repository ?

examples/dynamic.rs (line 45)

39async fn main() {
40    let ctx = Context::new();
41
42    MyActor::run(ctx.clone(), "actor 1", 1);
43    let actor_2_task = MyActor::run(ctx.clone(), "actor 2", 2);
44
45    let sender_1 = ctx.actor_sender::<Value>("actor 1");
46    sender_1.send(Value(11)).await.ok();
47    sender_1.send(Value(12)).await.ok();
48
49    let sender_2 = ctx.actor_sender::<Value>("actor 2");
50    sender_2.send(Value(21)).await.ok();
51    sender_2.send(Value(22)).await.ok();
52
53    sender_2.send(Value(0)).await.ok();
54    ctx.join(&actor_2_task).await.ok();
55
56    MyActor::run(ctx.clone(), "actor 2", 2);
57
58    let sender_2 = ctx.actor_sender::<Value>("actor 2");
59    sender_2.send(Value(23)).await.ok();
60
61    ctx.shutdown().await;
62}

Source

pub fn actor_receiver<M: Message>( &self, actor_id: impl Into<ActorId>, ) -> <M::Channel as Channel>::Receiver

Examples found in repository ?

examples/dynamic.rs (line 15)

14    fn run(ctx: Context, actor_id: &'static str, value: u32) -> TaskId {
15        let mut value_in = ctx.actor_receiver::<Value>(actor_id);
16        let mut actor = MyActor { value };
17
18        println!("run the {actor_id}");
19        ctx.clone().spawn(async move {
20            truba::event_loop!(ctx, {
21                Some(msg) = value_in.recv() => {
22                    actor.handle_value(msg);
23                    if actor.value == 0 {
24                        break;
25                    }
26                },
27            });
28            println!("stop the {actor_id}");
29        })
30    }