framez 0.4.0

A zerocopy codec for encoding and decoding data in no_std environments.
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

//! ```not_rust
//! cargo run --example zerocopy --features tracing
//! ```

use core::error::Error;

use embedded_io_adapters::tokio_1::FromTokio;
use framez::{FramedRead, FramedWrite, codec::lines::StrLines, next};

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    tracing_subscriber::fmt()
        .with_env_filter("reader=info,writer=info,framez=trace")
        .init();

    let (read, write) = tokio::io::duplex(8);

    let read_buf = &mut [0u8; 1024];
    let mut framed_read = FramedRead::new(StrLines::new(), FromTokio::new(read), read_buf);

    let reader = async move {
        while let Some(item) = next!(framed_read).transpose()? {
            tracing::info!(target: "reader", item, "received frame")
        }

        Ok::<(), Box<dyn Error>>(())
    };

    let write_buf = &mut [0u8; 1024];
    let mut framed_write = FramedWrite::new(StrLines::new(), FromTokio::new(write), write_buf);

    let writer = async move {
        let items = ["Hello, world!", "How are you?", "Goodbye!"];

        for item in items {
            tracing::info!(target: "writer", item, "sending frame");

            framed_write.send(item).await?;
        }

        Ok::<(), Box<dyn Error>>(())
    };

    let (reader_result, writer_result) = tokio::join!(reader, writer);

    reader_result?;
    writer_result?;

    Ok(())
}