async-flow 0.1.5

Async abstractions for flow-based programming (FBP).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

// This is free and unencumbered software released into the public domain.

use super::Outputs;
use crate::error::{Error, Result};
use core::str::FromStr;

pub async fn stdin<T: FromStr>(outputs: Outputs<T>) -> Result {
    use std::io::ErrorKind;
    use tokio::io::{AsyncBufReadExt, BufReader};

    let input = tokio::io::stdin();
    let reader = BufReader::new(input);
    let mut lines = reader.lines();

    while let Some(line) = lines.next_line().await? {
        let output = line
            .parse()
            .map_err(|_| Error::Stdio(ErrorKind::InvalidInput.into()))?;
        outputs.send(output).await?;
    }

    Ok(())
}