tokactor 2.1.0

A actor model framework wrapped around tokio
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use crate::{
    actor::InternalHandler,
    message::{AnonymousTaskCancelled, IntoFutureShutdown},
    Actor, Ctx,
};

impl<A: Actor> InternalHandler<IntoFutureShutdown<A>> for A {
    fn private_handler(&mut self, message: IntoFutureShutdown<A>, context: &mut Ctx<Self>) {
        if message.stop_now {
            context.subscribe_and_stop(message.tx);
        } else {
            context.subscribe_and_wait(message.tx);
        }
    }
}

impl<A: Actor> InternalHandler<AnonymousTaskCancelled> for A {
    fn private_handler(&mut self, message: AnonymousTaskCancelled, _: &mut Ctx<Self>) {
        // TODO(Alec): Add tracing here
        use AnonymousTaskCancelled::*;
        match message {
            Success => {}
            Cancel => tracing::trace!(actor = A::name(), private_event = "cancelled"),
            Panic => tracing::trace!(actor = A::name(), private_event = "panic"),
        }
    }
}

// impl<M: Message, A: Actor + Handler<M>> Ask<M> for A {
//     type Result = ();

//     fn handle(&mut self, message: M, context: &mut Ctx<Self>) {
//         self.handle(message, context);
//     }
// }

// impl<M: Message, A: Actor + Ask<M>> AsyncAsk<M> for A {
//     type Result = <A as Ask<M>>::Result;

//     fn handle(&mut self, message: M, context: &mut Ctx<Self>) -> AsyncHandle<Self::Result> {
//         let reply = self.handle(message, context);
//         context.anonymous_handle(async move { reply })
//     }
// }