Struct OwnedSemaphore 

pub struct OwnedSemaphore { /* private fields */ }

An owned semaphore is identical to a Semaphore except it can be owned by an actor and it’s permits can still be shared externally.

Implementations

impl OwnedSemaphore

pub fn new(permits: usize) -> Self

Creates a new instance of OwnedSemaphore with the given permits count that can be used with owned permits.

This can be used to create a owned semaphore that lives in a state:

use hydra::OwnedSemaphore;

struct MyServer {
    rate_limit: OwnedSemaphore,
}

impl MyServer {
    pub fn new() -> Self {
        Self {
            rate_limit: OwnedSemaphore::new(100),
        }
    }
}

pub async fn acquire(&self) -> SemaphorePermit<'_>

Acquires one permit asynchronously waiting for one to become available.

pub async fn acquire_owned(&self) -> OwnedSemaphorePermit

Acquires one permit asynchronously waiting for one to become available.

pub async fn acquire_many(&self, count: u32) -> SemaphorePermit<'_>

Acquires many permits asynchronously waiting for them to become available.

pub async fn acquire_many_owned(&self, count: u32) -> OwnedSemaphorePermit

Acquires many permits asynchronously waiting for them to become available.

pub fn try_acquire(&self) -> Result<SemaphorePermit<'_>, NoPermits>

Attempts to acquire a permit, returning an error if there are none available.

pub fn try_acquire_owned(&self) -> Result<OwnedSemaphorePermit, NoPermits>

Attempts to acquire a permit, returning an error if there are none available.