embystream 0.0.28

Another Emby streaming application (frontend/backend separation) written in Rust.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::sync::{Arc, OnceLock};
use tokio::sync::Semaphore;

pub struct RateLimiter {
    pub semaphore: Arc<Semaphore>,
    /// When true, local streaming skips per-chunk semaphore acquire (node `client_speed_limit_kbs == 0`).
    pub skip_semaphore: bool,
}

impl RateLimiter {
    /// No per-client byte cap (non-Disk local paths, missing cache entry, or `client_speed_limit_kbs == 0`).
    pub fn unlimited() -> Arc<Self> {
        static UNLIMITED: OnceLock<Arc<RateLimiter>> = OnceLock::new();
        UNLIMITED
            .get_or_init(|| {
                Arc::new(Self {
                    semaphore: Arc::new(Semaphore::new(Semaphore::MAX_PERMITS)),
                    skip_semaphore: true,
                })
            })
            .clone()
    }
}