use std::io;
use tokio::stream::StreamExt;
use tokio_util::codec::{FramedRead, LinesCodec};

#[tokio::main]
async fn main() -> io::Result<()> {
    // convert stdin into a nonblocking file;
    // this is the only part that makes use of tokio_file_unix
    let file = tokio_file_unix::raw_stdin()?;
    let file = tokio_file_unix::File::new_nb(file)?;

    let mut framed = FramedRead::new(file, LinesCodec::new());

    println!("Type something and hit enter!");
    while let Some(got) = framed.next().await {
        println!("Got: {:?}", got);
    }

    Ok(())
}