netmod-mem 0.4.0

A fully in-memory implementation of a netmod endpoint
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

use async_std;
use netmod_mem::MemMod;
use ratman_netmod::{Endpoint, Frame, Target};

#[async_std::test]
async fn ping_pong() {
    let a = MemMod::new();
    let b = MemMod::new();
    a.link(&b);

    a.send(Frame::dummy(), Target::default())
        .await
        .expect("Failed to send message from a. Error");
    b.next().await.expect("Failed to get message at b. Error");

    b.send(Frame::dummy(), Target::default())
        .await
        .expect("Failed to send message from b. Error");
    a.next().await.expect("Failed to get message at a. Error");
}

#[async_std::test]
async fn split() {
    let a = MemMod::new();
    let b = MemMod::new();
    a.link(&b);
    a.send(Frame::dummy(), Target::default())
        .await
        .expect("Failed to send message from a. Error");
    // Disconnect the two interfaces, so the message sent by A will never be
    // received by B.
    b.split();
    assert!(b.next().await.is_err());
}