termion-input-tokio

一个适配器，将termion的输入和按键事件迭代器暴露为异步流。

兼容性

与Tokio v1.0兼容。

用法

use futures::StreamExt;
use std::future;
use termion::{event::Key, raw::IntoRawMode};
use termion_input_tokio::TermReadAsync;

#[tokio::main]
async fn main() -> Result<(), std::io::Error> {
    // Disable line buffering, local echo, etc.
    let _raw_term = std::io::stdout().into_raw_mode()?;

    tokio::io::stdin()
        .keys_stream()
        // End the stream when 'q' is pressed.
        .take_while(|event| {
            future::ready(match event {
                Ok(Key::Char('q')) => false,
                _ => true,
            })
        })
        // Print each key that was pressed.
        .for_each(|event| async move {
            println!("{:?}\r", event);
        })
        .await;

    Ok(())
}

非阻塞输入

在stdin中使用真正的非阻塞读取是具有挑战性的。在常见情况下，stdin和stdout都指向相同的文件，通常是PTY。由于非阻塞模式是每个文件的属性，而不是每个文件描述符的属性，使用fcntl和O_NONBLOCK来将stdin变为非阻塞模式也将使stdout变为非阻塞。由于大多数代码在向stdout写入时没有准备好处理EWOULDBLOCK，因此通常使用阻塞操作在辅助线程上执行异步读取。这就是tokio::io::stdin()实现的AsyncRead的方式。

致谢

这是基于Kayo Phoenix的termion-tokio，它又基于termion中的代码。