Struct jsonrpsee_core::server::helpers::BoundedSubscriptions

pub struct BoundedSubscriptions { /* private fields */ }

Wrapper over tokio::sync::Notify with bounds check.

Implementations

impl BoundedSubscriptions

pub fn new(max_subscriptions: u32) -> Self

Create a new bounded subscription.

pub fn acquire(&self) -> Option<SubscriptionPermit>

Attempts to acquire a subscription slot.

Fails if max_subscriptions have been exceeded.

pub const fn max(&self) -> u32

Get the maximum number of permitted subscriptions.

pub fn close(&self)

Close all subscriptions.

Trait Implementations

impl Clone for BoundedSubscriptions

fn clone(&self) -> BoundedSubscriptions

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BoundedSubscriptions

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.