flexaudio 0.4.0

Flexible cross-platform audio capture (microphone, system loopback, per-process) for Linux, Windows, and macOS with a unified API.
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

//! Durable terminal capture state, independent of capture-thread lifetime.

use std::sync::atomic::{AtomicBool, Ordering};
use std::sync::Mutex;

use flexaudio_core::types::Error;

#[derive(Default)]
pub(super) struct TerminalFailure {
    failed: AtomicBool,
    error: Mutex<Option<Error>>,
}

impl TerminalFailure {
    pub(super) fn is_failed(&self) -> bool {
        self.failed.load(Ordering::SeqCst)
    }

    pub(super) fn error(&self) -> Option<Error> {
        self.error.lock().unwrap_or_else(|e| e.into_inner()).clone()
    }

    /// Caller holds the delivery lock. Publish the cause before closing delivery.
    /// Returns true only for the first failure (one terminal event per stream).
    pub(super) fn record(&self, cause: Error) -> bool {
        let mut error = self.error.lock().unwrap_or_else(|e| e.into_inner());
        if error.is_some() {
            return false;
        }
        *error = Some(cause);
        self.failed.store(true, Ordering::SeqCst);
        true
    }
}