sib 0.0.17

A high-performance, secure, and cross-platform modules optimized for efficiency, scalability, and reliability.
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
37
38

use crossbeam::channel::{Receiver, Sender, unbounded};

#[derive(Debug)]
pub enum Command {
    SetBitrate(u32),
    SetFps(u32),
    SetResolution(u32, u32),
    Stop,
}

#[derive(Clone)]
pub struct ControlHandle {
    tx: Sender<Vec<Command>>,
    rx: Receiver<Vec<Command>>,
}

impl Default for ControlHandle {
    fn default() -> Self {
        Self::new()
    }
}

impl ControlHandle {
    pub fn new() -> Self {
        let (tx, rx) = unbounded();
        Self { tx, rx }
    }

    /// Send a batch of commands
    pub fn send(&self, cmds: Vec<Command>) {
        let _ = self.tx.send(cmds);
    }

    /// Receive a batch of commands if available
    pub fn try_recv(&self) -> Option<Vec<Command>> {
        self.rx.try_recv().ok()
    }
}