polybox-core 0.0.2

Message-passing abstractions to make working with channels and actors a more seamless experience
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

use super::*;
use std::any::TypeId;
use type_sets::Members;

/// An interface defines the set of messages that can be sent to a given actor.
/// This is usually derived on an enum using the `#[derive(Interface)]` macro.
///
/// It defines conversion methods to and from a boxed payload, which is used for dynamic dispatch of messages.
pub trait Interface:
    Message<Kind = FireAndForget>
    + TryIntoPayload<Self>
    + FromPayload<Self>
    + AsSet
    + Sized
    + Send
    + 'static
{
    fn try_from_boxed_payload(payload: BoxedPayload) -> Result<Self, BoxedPayload>;
    fn into_boxed_payload(self) -> BoxedPayload;

    fn try_from_any_payload<I: Message>(payload: Payload<I>) -> Result<Self, Payload<I>>
    where
        Payload<I>: Send,
    {
        // This can be implemented faster using unsafe transmute
        Self::try_from_boxed_payload(BoxedPayload::new::<I>(payload))
            .map_err(|payload| payload.downcast::<I>().expect("Conversion back"))
    }

    fn try_into_any_payload<I: Message>(self) -> Result<Payload<I>, Self> {
        // This can be implemented faster using unsafe transmute
        self.into_boxed_payload()
            .downcast::<I>()
            .map_err(|payload| Self::try_from_boxed_payload(payload).expect("Conversion back"))
    }

    fn invocable_with(type_id: TypeId) -> bool {
        Self::members().contains(&type_id)
    }
}

pub trait FromPayload<T: Message> {
    fn from_payload(payload: Payload<T>) -> Self;
}

pub trait TryIntoPayload<T: Message>: Sized {
    fn try_into_payload(self) -> Result<Payload<T>, Self>;
}