Struct BoundedSubscriptions

pub struct BoundedSubscriptions { /* private fields */ }

Available on crate feature server-core only.

This wraps tokio::sync::Semaphore and is used to limit the number of subscriptions per connection.

Implementations

impl BoundedSubscriptions

pub fn new(max_subscriptions: u32) -> BoundedSubscriptions

Create a new bounded subscription.

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

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.

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<(), Error>

Formats the value using the given formatter.