wiremix 0.11.0

A TUI mixer for PipeWire
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

use std::collections::HashSet;

use libspa::utils::result::AsyncSeq;
use pipewire::core::Core;

/// Track pending syncs in order to determine when wirehose has all initial
/// information and is waiting for new events.
#[derive(Default)]
pub struct SyncRegistry {
    pending: HashSet<i32>,
    done: bool,
}

impl SyncRegistry {
    /// Register a pending sync.
    pub fn global(&mut self, core: &Core) {
        if !self.done {
            if let Ok(seq) = core.sync(0) {
                self.pending.insert(seq.seq());
            }
        }
    }

    /// Mark a sync as done, return true when all are done for the first time.
    pub fn done(&mut self, seq: AsyncSeq) -> bool {
        if self.done {
            return false;
        }

        self.pending.remove(&seq.seq());
        self.done |= self.pending.is_empty();
        self.pending.is_empty()
    }
}