mm1-server 0.7.22

An Erlang-style actor runtime for Rust.
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

use futures::never::Never;
use mm1_common::types::AnyError;
use mm1_proto_ask::RequestHeader;

use crate::outcome::Outcome;

pub trait OnMessage<Ctx, M>: Send {
    fn on_message(
        &mut self,
        ctx: &mut Ctx,
        message: M,
    ) -> impl Future<Output = Result<Outcome<M, Never>, AnyError>> + Send;
}

pub trait OnRequest<Ctx, Rq>: Send {
    type Rs;

    fn on_request(
        &mut self,
        ctx: &mut Ctx,
        reply_to: RequestHeader,
        request: Rq,
    ) -> impl Future<Output = Result<Outcome<Rq, Self::Rs>, AnyError>> + Send;
}