Message responses using regular [lunatic] processes.
Regular lunatic processes don't typically support sending responses in messages.
This library provides a type MessageRequest
which adds support for replying back with a value.
```rust use lunatic::spawnlink; use lunaticmessage_request::{MessageRequest, ProcessRequest}; use serde::{Deserialize, Serialize};
enum Message { Inc, Dec, Count(MessageRequest<(), i32>), }
let counter = spawn_link!(|mailbox: Mailbox
loop {
let msg = mailbox.receive();
match msg {
Message::Inc => count += 1,
Message::Dec => count -= 1,
Message::Count(req) => req.reply(count),
}
}
});
// Initial count should be 0 let count = counter.request(Message::Count, ()); assert_eq!(count, 0);
// Increment count counter.send(Message::Inc);
// Count should now be 1 let count = counter.request(Message::Count, ()); assert_eq!(count, 1); ```
Licensed under either
at your option.