use futures::StreamExt;
use blehr::{Error, Scanner};
#[tokio::main]
async fn main() -> Result<(), Box<Error>> {
let mut scanner = Scanner::new().await?;
loop {
scanner.start().await?;
println!("Scanning for HR sensors ...");
let mut sensor = scanner.next_sensor().await?.unwrap();
println!(
"Found {}",
sensor
.name()
.await
.unwrap_or_else(|| "unknown sensor".to_string())
);
scanner.stop().await?;
if let Ok(mut hr_stream) = sensor.hr_stream().await {
while let Some(hr) = hr_stream.next().await {
println!("hr: {:?}", hr);
}
}
}
}