pipecrab-runtime 0.7.0

Runtime-agnostic async orchestration for pipecrab: Inbound, Outbound. Built on futures.
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

use futures::executor::block_on;
use pipecrab_core::{DataFrame, Direction, SystemFrame, Transcript};
use pipecrab_runtime::{Received, link};

#[test]
fn send_data_delivers_frame() {
    block_on(async {
        let (outb, mut inb) = link(8);

        outb.send_data(Transcript::user_final("hello").into())
            .await
            .unwrap();

        match inb.recv().await.unwrap() {
            Received::Data(DataFrame::Transcript(s)) => assert_eq!(s.text, "hello".into()),
            other => panic!("unexpected {other:?}"),
        }
    });
}

#[test]
fn send_system_preserves_direction() {
    block_on(async {
        let (outb, mut inb) = link(8);

        outb.send_system(
            Direction::Up,
            SystemFrame::Error {
                message: "boom".into(),
                fatal: false,
            },
        )
        .await
        .unwrap();

        match inb.recv().await.unwrap() {
            Received::Sys(Direction::Up, SystemFrame::Error { message, .. }) => {
                assert_eq!(message, "boom".into())
            }
            other => panic!("unexpected {other:?}"),
        }
    });
}

#[test]
fn send_data_to_closed_channel_returns_err() {
    block_on(async {
        let (outb, inb) = link(8);
        drop(inb);

        assert!(
            outb.send_data(Transcript::user_final("x").into())
                .await
                .is_err()
        );
    });
}

#[test]
fn send_system_to_closed_channel_returns_err() {
    block_on(async {
        let (outb, inb) = link(8);
        drop(inb);

        assert!(
            outb.send_system(Direction::Down, SystemFrame::Stop)
                .await
                .is_err()
        );
    });
}