simple-message-channels 0.2.0

Simple binary protocol with a channel, type, message scheme
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use async_std::{io, task};
use simple_message_channels::{Message, Writer};

fn main() {
    task::block_on(async move { send().await.unwrap() });
}

async fn send() -> io::Result<()> {
    let stdout = io::stdout().lock().await;
    let mut writer = Writer::new(stdout);
    for i in 0..3 {
        let message = Message::new(i, 1, "hi".as_bytes().to_vec());
        print_msg(&message);
        writer.send(message).await?;
    }
    Ok(())
}

fn print_msg(msg: &Message) {
    let text = String::from_utf8(msg.message.clone()).unwrap();
    eprintln!("send: ch {} typ {}: {}", msg.channel, msg.typ, text);
}