lasprs 0.14.1

Library for Acoustic Signal Processing (Rust edition, with optional Python bindings via pyo3)
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use anyhow::Result;
use crossbeam::channel::{Receiver, TryRecvError, unbounded};
use lasprs::daq::{InStreamMsg, StreamHandler, StreamMgr};
use std::io;
use std::{thread, time};
// use

fn spawn_stdin_channel() -> Receiver<String> {
    let (tx, rx) = unbounded();
    thread::spawn(move || {
        loop {
            let mut buffer = String::new();
            io::stdin().read_line(&mut buffer).unwrap();
            tx.send(buffer).unwrap();
        }
    });
    rx
}
fn sleep(millis: u64) {
    let duration = time::Duration::from_millis(millis);
    thread::sleep(duration);
}
fn main() -> Result<()> {
    let mut smgr = StreamMgr::new();

    smgr.startDefaultInputStream()?;
    let stdin_channel = spawn_stdin_channel();

    let sh = StreamHandler::new(&mut smgr);

    'infy: loop {
        match stdin_channel.try_recv() {
            Ok(_key) => break 'infy,
            Err(TryRecvError::Empty) => {}
            Err(TryRecvError::Disconnected) => panic!("Channel disconnected"),
        }
        sleep(100);
        match sh.rx.try_recv() {
            Ok(msg) => {
                // eprint!("Obtained message: {:?}", msg);
                match msg {
                    InStreamMsg::StreamStarted(meta, _) => {
                        println!("Stream started metadata: {meta:#?}");
                    }
                    InStreamMsg::InStreamData(_) => {}
                    _ => {
                        println!("Instreamdata arrived...");
                    }
                }
            }
            Err(e) => match e {
                TryRecvError::Disconnected => {
                    break 'infy;
                }
                TryRecvError::Empty => {}
            },
        }
    }

    Ok(())
}