use tokio_stream::StreamExt;
use code_scanner_driver::stream::ScannerStream;
#[tokio::main]
async fn main() {
let mut stream = ScannerStream::new().unwrap();
println!("Listening... scan something:");
while let Some(ev) = stream.next().await {
println!("Received: {:?}", ev);
}
}