viser-encoding 0.6.2

Shared encoding configuration, preset mapping, temp cleanup for viser
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

use std::sync::atomic::{AtomicI64, Ordering};
use tokio::sync::mpsc;
use tracing::debug;

/// Non-blocking progress sender. Logs when updates are dropped due to a full channel.
pub struct ProgressSender<T> {
    tx: Option<mpsc::Sender<T>>,
    dropped: AtomicI64,
}

impl<T> ProgressSender<T> {
    /// Creates a sender wrapping an optional channel; `None` makes `send` a no-op.
    pub fn new(tx: Option<mpsc::Sender<T>>) -> Self {
        Self { tx, dropped: AtomicI64::new(0) }
    }

    /// Attempts to send a progress update. Non-blocking.
    pub fn send(&self, value: T) {
        let Some(ref tx) = self.tx else { return };
        match tx.try_send(value) {
            Ok(()) => {}
            Err(mpsc::error::TrySendError::Full(_)) => {
                let count = self.dropped.fetch_add(1, Ordering::Relaxed) + 1;
                if count == 1 || count % 100 == 0 {
                    debug!("progress update dropped (channel full), total_dropped={count}");
                }
            }
            Err(mpsc::error::TrySendError::Closed(_)) => {}
        }
    }

    /// Returns the number of updates dropped so far because the channel was full.
    pub fn dropped(&self) -> i64 {
        self.dropped.load(Ordering::Relaxed)
    }
}