lasprs 0.4.1

Library for Acoustic Signal Processing (Rust edition, with optional Python bindings via pyo3)
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
29
30
31
32
33
34
35
36

//! Provides stream messages that come from a running stream
use crate::config::*;
use crate::daq::Qty;
use crate::siggen::Siggen;
use anyhow::{bail, Result};
use streamdata::*;
use crossbeam::channel::Sender;
use reinterpret::{reinterpret_slice, reinterpret_vec};
use std::any::TypeId;
use std::sync::{Arc, RwLock};
use std::u128::MAX;
use strum_macros::Display;

use super::*;

/// Input stream messages, to be send to handlers.
#[derive(Clone, Debug)]
pub enum InStreamMsg {
    /// Raw stream data that is coming from a device. This is interleaved data. The number of channels is correct and
    /// specified in the stream metadata.
    StreamData(Arc<StreamData>),

    /// An error has occured in the stream
    StreamError(StreamError),

    /// Stream data converted to floating point with sample width as
    /// compiled in.
    ConvertedStreamData(usize, Arc<crate::config::Dmat>),

    /// new Stream metadata enters the scene. Probably a new stream started.
    StreamStarted(Arc<StreamMetaData>),

    /// An existing stream stopped.
    StreamStopped,
}