Simple streamable state machine that implements a useful channel, message-type, message pattern.
A port of the JavaScript module simple-message-channels to Rust. Original module by mafintosh.
See examples/.
The following sends three messages, transforms them, and prints the results:
```sh cargo run --example send | cargo run --example echo_upper | cargo run --example recv
```
This example would read messages from STDIN and echos them back to STDOUT:
rust
async fn echo() -> Result<(), io::Error> {
let stdin = io::stdin().lock().await;
let stdout = io::stdout().lock().await;
let mut reader = Reader::new(stdin);
let mut writer = Writer::new(stdout);
while let Some(msg) = reader.next().await {
let msg = msg?;
writer.send(msg).await?;
}
Ok(())
}