meslin 0.0.4

Ergonomic messaging 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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use ::type_sets::Set;
use meslin::*;

/// Example protocol that can be used
#[derive(Debug, From, TryInto, DynFromInto)]
pub enum MyProtocol {
    A(u32),
    B(HelloWorld),
    C(Request<u32, String>),
}

#[derive(Debug, Message, From)]
#[from(forward)]
pub struct HelloWorld(pub String);

#[tokio::test]
async fn test() {
    let (sender, _receiver) = mpmc::unbounded::<MyProtocol>();

    let _ = sender.clone().into_dyn::<Set![u32]>();

    let boxed_sender = sender.clone().into_boxed();
    boxed_sender
        .dyn_send::<HelloWorld>("Hello world!")
        .await
        .unwrap();

    let dyn_sender = <DynSender![HelloWorld]>::from_boxed_unchecked(boxed_sender);
    dyn_sender
        .dyn_send::<HelloWorld>("Hello world!")
        .await
        .unwrap();

    let dyn_sender = <DynSender![HelloWorld, u32]>::new(sender.clone());
    let dyn_sender = dyn_sender.transform::<Set![u32]>();

    let dyn_sender = dyn_sender.try_transform::<Set![HelloWorld]>().unwrap();
    dyn_sender.try_transform::<Set![u64, u32]>().unwrap_err();
}