Struct SubscriptionRegistry 

pub struct SubscriptionRegistry { /* private fields */ }

Subscription-Registry. Pro WebSocket-Connection ein Set von Topics.

Implementations

impl SubscriptionRegistry

pub fn new() -> Self

Konstruktor.

pub fn subscribe(&mut self, conn_id: u64, topic: String, sub_id: Option<String>)

Subscribe.

pub fn unsubscribe(&mut self, conn_id: u64, topic: &str) -> bool

Unsubscribe.

pub fn drop_connection(&mut self, conn_id: u64)

Connection schliessen — entfernt alle ihre Subscriptions.

pub fn subscribers_of(&self, topic: &str) -> Vec<(u64, Option<String>)>

Liste aller Connections, die einen Topic abonniert haben. Liefert (conn_id, optional sub_id)-Tupel.

pub fn connection_count(&self) -> usize

Anzahl Connections.

pub fn subscription_count(&self) -> usize

Anzahl Subscriptions ueber alle Connections.

Trait Implementations

impl Clone for SubscriptionRegistry

fn clone(&self) -> SubscriptionRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionRegistry

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

Formats the value using the given formatter.

impl Default for SubscriptionRegistry

fn default() -> SubscriptionRegistry

Returns the “default value” for a type.

impl PartialEq for SubscriptionRegistry

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for SubscriptionRegistry

impl StructuralPartialEq for SubscriptionRegistry