# simple-message-channels

Simple streamable state machine that implements a useful channel, message-type, message pattern.

A port of the JavaScript module [simple-message-channels](https://github.com/mafintosh/simple-message-channels) to Rust. Original module by [mafintosh](https://github.com/mafintosh).

* [Docs](https://docs.rs/simple-message-channels)

## Examples

See [examples/](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(())
}
```