datapipe 0.1.4

Stream data from here to there
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

use crate::datapipe_types::InputReader;
/// Reader for STDIN
use bytes::{Bytes, BytesMut};
use std::io::Error;
use tokio::io::AsyncReadExt;

#[derive(Debug)]
pub struct StdinReader {}

impl StdinReader {
    pub fn new() -> Self {
        Self {}
    }
}

impl InputReader for StdinReader {
    async fn read(&mut self) -> Result<Bytes, Error> {
        let mut bytes = BytesMut::new();
        match tokio::io::stdin().read_buf(&mut bytes).await {
            Ok(_bytes_read) => Ok(bytes.freeze()),
            Err(error) => Err(error),
        }
    }
}

impl Default for StdinReader {
    fn default() -> Self {
        Self::new()
    }
}