/** Example program showing how to read a multi-channel time-series in LSL in a chunk-by-chunk
manner, which is an easy way to read in a non-blocking fashion.*/
use lsl;
use lsl::Pullable; // trait that provides the pull_chunk method
fn main() -> Result<(), lsl::Error> {
// first we're resolving a stream with content type EEG on the network
println!("Resolving EEG stream...");
let res = lsl::resolve_byprop("type", "EEG", 1, lsl::FOREVER)?;
// next we create an inlet to read from the stream, using default parameters
let inl = lsl::StreamInlet::new(&res[0], 360, 0, true)?;
println!("Reading data...");
loop {
// read all new samples and their time stamps since our last call
let (samples, stamps): (Vec<Vec<f32>>, _) = inl.pull_chunk()?;
// print them
for k in 0..samples.len() {
println!("got {:?} at time {}", samples[k], stamps[k]);
}
println!("---");
// wait for some amount until we read a new chunk -- how long you wait depends on your
// application, but if we don't sleep then the loop would spin very fast and pin a CPU core
std::thread::sleep(std::time::Duration::from_millis(16));
}
}