chore: Add blocking io example. (#90)

Author: jettify

Cargo.toml

@@ -36,6 +36,13 @@ required-features = ["embedded_io_async"]
 test = false
 
 
+[[example]]
+name = "blocking"
+path = "examples/local_blocking.rs"
+required-features = ["embedded_io"]
+test = false
+
+
 [[example]]
 name = "raw"
 path = "examples/local_raw.rs"

examples/local_blocking.rs

@@ -0,0 +1,65 @@
+use embedded_io::ErrorKind;
+use embedded_io_adapters::std::FromStd;
+use std::env;
+use std::process::exit;
+use std::time::Duration;
+use uf_crsf::blocking_io::BlockingCrsfReader;
+use uf_crsf::error::CrsfStreamError;
+
+fn main() {
+    let ports = match serialport::available_ports() {
+        Ok(ports) => ports,
+        Err(e) => {
+            eprintln!("Failed to enumerate serial ports: {}", e);
+            exit(1);
+        }
+    };
+
+    if ports.is_empty() {
+        eprintln!("No serial ports found.");
+        eprintln!("Please specify a serial port path as an argument.");
+        exit(1);
+    }
+
+    let path = env::args().nth(1).unwrap_or_else(|| {
+        const DEFAULT_PORT: &str = "/dev/tty.usbmodem00000000001B1";
+        if ports.iter().any(|p| p.port_name == DEFAULT_PORT) {
+            println!(
+                "No serial port specified. Using default port: {}",
+                DEFAULT_PORT
+            );
+            DEFAULT_PORT.to_string()
+        } else {
+            println!("No serial port specified. Available ports:");
+            for p in &ports {
+                println!("  {}", p.port_name);
+            }
+            println!("\nUsing first available port: {}", ports[0].port_name);
+            ports[0].port_name.clone()
+        }
+    });
+
+    let mut port = serialport::new(&path, 420_000)
+        .timeout(Duration::from_millis(10))
+        .open()
+        .unwrap_or_else(|e| {
+            eprintln!("Failed to open serial port '{}': {}", &path, e);
+            exit(1);
+        });
+
+    let adapted_port = FromStd::new(&mut port);
+    let mut reader = BlockingCrsfReader::new(adapted_port);
+    println!("Reading from serial port '{}'...", path);
+
+    loop {
+        match reader.read_packet() {
+            Ok(packet) => {
+                println!("{:?}", packet);
+            }
+            Err(CrsfStreamError::Io(ErrorKind::TimedOut)) => {}
+            Err(e) => {
+                eprintln!("Error reading from serial port: {:?}", e);
+            }
+        }
+    }
+}

justfile

@@ -59,6 +59,12 @@ example_simple:
 example_async:
   cargo run --example=async --all-features
 
+# Run example local_simple that parses hard coded buffer.
+[group('examples')]
+example_blocking:
+  cargo run --example=blocking --all-features
+
+
 # Lint source code with strict linter
 [group('lint')]
 pedantic: