lasprs 0.14.0

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

use std::ops::Deref;

use super::*;
use crossbeam::channel::{Receiver, unbounded};
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();

        // The queue there is not 'drop()' in streamhandler, as StreamMgr
        // detects on its own when the stream other end of the channel is
        // dropped.
        smgr.addInQueue(tx);
        StreamHandler { rx }
    }
}
impl Deref for StreamHandler {
    type Target = Receiver<InStreamMsg>;

    fn deref(&self) -> &Self::Target {
        &self.rx
    }
}