ractor 0.16.5

A actor framework for Rust
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
use ractor::RpcReplyPort;

struct MissingReplyActor;

enum Message {
    Read(u64, RpcReplyPort<u64>),
}

#[ractor::actor(message = Message)]
impl MissingReplyActor {
    #[ractor::rpc(Message::Read(value, reply))]
    fn read(&self, value: u64, reply: RpcReplyPort<u64>) -> u64 {
        value + usize::from(reply.is_closed()) as u64
    }
}

fn main() {}