dptree 0.5.1

An asynchronous event dispatch mechanism 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

use dptree::prelude::*;
use std::net::Ipv4Addr;

fn assert_num_string_handler(
    expected_num: u32,
    expected_string: &'static str,
) -> Endpoint<'static, ()> {
    // The handler requires `u32` and `String` types from the input storage.
    dptree::endpoint(move |num: u32, string: String| async move {
        assert_eq!(num, expected_num);
        assert_eq!(string, expected_string);
    })
}

#[tokio::main]
async fn main() {
    // Init the storage with `u32` and `String` values.
    let store = dptree::deps![10u32, "Hello".to_owned()];

    let h = assert_num_string_handler(10u32, "Hello");

    let _ = h.dispatch(store.clone()).await;

    // This will cause a panic because we do not store `Ipv4Addr` in out store.
    let handle = tokio::spawn(async move {
        let ip_handler: Endpoint<_> = dptree::endpoint(|ip: Ipv4Addr| async move {
            assert_eq!(ip, Ipv4Addr::new(0, 0, 0, 0));
        });
        let _ = ip_handler.dispatch(store).await;
    });
    let result = handle.await;
    assert!(result.is_err())
}