kithara-net 0.0.1-alpha4

Streaming HTTP for audio: retry, timeout, byte ranges.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::sync::{
    Arc,
    atomic::{AtomicUsize, Ordering},
};

#[derive(Clone, Default)]
pub(crate) struct ConnectionMetrics {
    opened: Arc<AtomicUsize>,
}

impl ConnectionMetrics {
    pub(crate) fn connection_count(&self) -> usize {
        self.opened.load(Ordering::SeqCst)
    }

    #[cfg(not(target_arch = "wasm32"))]
    pub(crate) fn record_opened_connection(&self) {
        self.opened.fetch_add(1, Ordering::SeqCst);
    }
}