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

use async_std::channel::{bounded, Receiver, Sender};
use ratman_netmod::Frame;

/// A simple I/O wrapper around channels
pub(crate) struct Io {
    pub out: Sender<Frame>,
    pub inc: Receiver<Frame>,
}

impl Io {
    pub(crate) fn make_pair() -> (Io, Io) {
        let (a_to_b, b_from_a) = bounded(1);
        let (b_to_a, a_from_b) = bounded(1);
        let a = Io {
            out: a_to_b,
            inc: a_from_b,
        };
        let b = Io {
            out: b_to_a,
            inc: b_from_a,
        };
        return (a, b);
    }
}