bombay-behavior 0.11.0

Composable, statically typed actor behavior algebra
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
45
46
47
48
49
50
51
52

//! The event coproduct shared by timer-based behavior compositions.

use crate::behavior::{User, UserEvent};
use crate::protocol::TimerElapsed;
use crate::protocol::forward::forward_event_lane;

#[derive(Debug, Clone, PartialEq, Eq)]
pub enum TimedEvent<E> {
    Behavior(E),
    Elapsed(TimerElapsed),
}

impl<E: UserEvent> crate::RouteInput<TimerElapsed> for TimedEvent<E> {
    fn route(event: TimerElapsed) -> Result<Self, TimerElapsed> {
        Ok(Self::Elapsed(event))
    }
}

impl<E: UserEvent> crate::EventInput<TimerElapsed> for TimedEvent<E> {
    fn inject(event: TimerElapsed) -> Self {
        Self::Elapsed(event)
    }
}

impl<E: UserEvent> UserEvent for TimedEvent<E> {
    type Addr = E::Addr;
    type Message = E::Message;

    fn user(from: Self::Addr, message: Self::Message) -> Self {
        Self::Behavior(E::user(from, message))
    }

    fn into_user(self) -> Result<User<Self::Addr, Self::Message>, Self> {
        match self {
            Self::Behavior(event) => event.into_user().map_err(Self::Behavior),
            elapsed @ Self::Elapsed(_) => Err(elapsed),
        }
    }
}

forward_event_lane!(TimedEvent, crate::PeerStopped<E::Addr>);
forward_event_lane!(TimedEvent, crate::ChildStopped<E::Addr>);
forward_event_lane!(TimedEvent, crate::WorkerStopped<E::Addr>);
forward_event_lane!(
    TimedEvent,
    crate::CreationResolved<<E::Addr as crate::Address>::Nonce>
);
forward_event_lane!(
    TimedEvent,
    crate::WorkerCreationResolved<<E::Addr as crate::Address>::Nonce>
);
forward_event_lane!(TimedEvent, crate::ShutdownRequested);