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


use crossbeam::channel::{unbounded, Receiver};
use super::*;
use streammsg::InStreamMsg;

/// A stream handler registers a queue in the stream manager, and keeps the other end to 
/// get InStreamData from a running input stream.
pub struct StreamHandler {
    /// The receiving part of the channel on which (InStreamData) is received..
    pub rx: Receiver<InStreamMsg>
}
impl StreamHandler {
    /// Create new stream handler.
    pub fn new(smgr: &mut StreamMgr) -> StreamHandler{
        let (tx, rx) = unbounded();
        smgr.addInQueue(tx);
        StreamHandler{rx}
    }
}