unb-client 2.0.3

unb outbound client: WebSocket + in-process dialing (native) over the sans-IO core; wasm-safe
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

use tokio::sync::mpsc;
use unb_core::Envelope;

use unb_runtime::Pipe;

/// Cross-wired in-process local pipes: frames pass as `Envelope` values, never
/// serialized. The first side is the initiator (dialer), the second the acceptor.
pub fn pair() -> (Pipe, Pipe) {
    let (a_to_b_tx, a_to_b_rx) = mpsc::channel::<Envelope>(64);
    let (b_to_a_tx, b_to_a_rx) = mpsc::channel::<Envelope>(64);
    (
        Pipe::Local {
            rx: b_to_a_rx,
            tx: a_to_b_tx,
            initiator: true,
        },
        Pipe::Local {
            rx: a_to_b_rx,
            tx: b_to_a_tx,
            initiator: false,
        },
    )
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn pair_has_opposite_roles() {
        let (dialer, listener) = pair();
        assert!(matches!(
            dialer,
            Pipe::Local {
                initiator: true,
                ..
            }
        ));
        assert!(matches!(
            listener,
            Pipe::Local {
                initiator: false,
                ..
            }
        ));
    }
}