spike_prime 1.1.1

Wrapper around the SPIKE Prime communication protocol.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use std::{io::stdout, time::Duration};

use crossterm::execute;
use spike_prime::prelude::*;

#[tokio::main]
async fn main() -> Result<()> {
    let manager = Manager::new().await?;
    let adapter = manager.adapters().await?.drain(..).next().unwrap();
    println!("Scanning for SPIKE Prime hubs");
    let device = SpikePrime::scan_first(&adapter).await?;
    println!("Device found!");
    let mut connection = device.connect().await?;
    connection.enable_device_notifications().await?;
    println!("Message sent");
    loop {
        let response = connection.device_notification().await;
        if let Some(n) = response {
            execute! {
                stdout(),
                crossterm::terminal::Clear(crossterm::terminal::ClearType::All),
                crossterm::cursor::MoveTo(0, 0),
            }?;
            println!("{n:?}");
        }
        tokio::time::sleep(Duration::from_millis(1)).await;
    }
}