input-linux-bug.rs

#!/usr/bin/env -S cargo +nightly -Zscript

---cargo
[dependencies]
futures = "0.3.31"
input-linux = { version = "0.7.1", features = ["codec", "tokio-util-0_7"] }
tokio = { version = "1.46.1", features = ["full"] }
tokio-util = { version = "0.7.15", features = ["full"] }
---


use futures::StreamExt;
use tokio_util::codec::FramedRead;

#[tokio::main]
async fn main() -> std::io::Result<()> {
    let input_file = tokio::fs::File::open("/dev/input/event2").await.unwrap();
    let mut event_stream = FramedRead::new(input_file, input_linux::EventCodec::new());

    println!("Press and hold any key to see bug");

    let mut i = 0;
    loop {
        i += 1;
        match event_stream.next().await {
            Some(Ok(event)) => {
                // the unwrap must not be optimized away
                std::hint::black_box(event);

                // do something
                use std::io::Write;
                std::io::stdout().write(b".").unwrap();
                std::io::stdout().flush().unwrap();
            }
            Some(Err(e)) => {
                println!("\nERROR reading event: {}\nERROR kind: {}", e, e.kind());
                break;
            }
            None => {
                println!("Stream ended");
                break;
            }
        }
    }

    println!("Encountered {} events before bug", i);
    Ok(())
}