Struct futures_rate::prelude::GateKeeper

pub struct GateKeeper { /* fields omitted */ }

Methods

impl GateKeeper

pub fn new(size: usize) -> Self

pub fn with_rate(count_per_interval: usize, interval: Duration) -> Self

pub fn register<R, F>(&self, fut: F) -> Option<Permit<R, F>> where
    R: Send + 'static,
    F: Future<Output = R> + 'static, 

Deprecated since 0.1.4:

This API is deprecated in favor of the issue() method, which avoids the deadlock issues as a whole. This API, along with the associated struct Permit, will be removed in the 0.1.5 release.

pub fn issue<R, F>(&self, fut: F) -> Option<impl Future<Output = R>> where
    R: Send + 'static,
    F: Future<Output = R> + 'static, 

pub fn issue_interruptable<R, F>(
    &self,
    fut: F
) -> Option<impl Future<Output = Result<R, InterruptedReason>>> where
    R: Send + 'static,
    F: Future<Output = R> + 'static, 

pub fn close(&self)

pub fn is_closed(&self) -> bool

Trait Implementations

impl Drop for GateKeeper

fn drop(&mut self)

Executes the destructor for this type.

impl GateKeeperConfig for GateKeeper

fn set_policy(&mut self, policy: TokenPolicy)

fn set_ratio(&mut self, ratio: RatioType)