Struct ConnectionLimit 

pub struct ConnectionLimit(/* private fields */);

Available on crate feature transport-http only.

Non-zero open-connection cap for HttpConfig::max_concurrent_connections, clamped to what tokio::sync::Semaphore supports.

Examples

use mcpls_core::ConnectionLimit;

assert!(ConnectionLimit::new(0).is_none());
assert_eq!(ConnectionLimit::new(8).unwrap().get(), 8);
assert!(ConnectionLimit::new(usize::MAX).is_some());

Implementations

impl ConnectionLimit

pub const DEFAULT: Self

512: room for 100 sessions each holding a GET stream, a subscriptions/listen stream and one in-flight POST.

pub fn new(max: usize) -> Option<Self>

None for zero; larger values are clamped to the most a tokio::sync::Semaphore supports.

pub const fn get(self) -> usize

The wrapped limit, between 1 and the most a tokio::sync::Semaphore supports.

Trait Implementations

impl Clone for ConnectionLimit

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ConnectionLimit

impl Debug for ConnectionLimit

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

Formats the value using the given formatter.

impl Eq for ConnectionLimit

impl PartialEq for ConnectionLimit

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ConnectionLimit