Struct GenericBroadcaster 

pub struct GenericBroadcaster<E: ToSse + Clone + Send + Sync> { /* private fields */ }

Implementations

impl<E: ToSse + Clone + Send + Sync> GenericBroadcaster<E>

pub fn new() -> Self

pub async fn connected_users(&self) -> Vec<String>

pub async fn connection_info(&self) -> (usize, usize)

Trait Implementations

impl<E: ToSse + Clone + Send + Sync + 'static> Broadcaster for GenericBroadcaster<E>

type Event = E

fn register<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 UserId, connection_id: &'life2 str, sender: EventSender, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn unregister<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 UserId, connection_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn broadcast<'life0, 'life1, 'async_trait>( &'life0 self, user_id: &'life1 UserId, event: Self::Event, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn connection_count<'life0, 'life1, 'async_trait>( &'life0 self, user_id: &'life1 UserId, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn total_connections<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<E: ToSse + Clone + Send + Sync> Debug for GenericBroadcaster<E>

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

Formats the value using the given formatter.

impl<E: ToSse + Clone + Send + Sync> Default for GenericBroadcaster<E>

fn default() -> Self

Returns the “default value” for a type.