Struct WebSocket

pub struct WebSocket { /* private fields */ }

Implementations

impl WebSocket

pub fn new() -> Self

pub fn receiver_count<'a, B: BroadcastTypeTrait>( &self, broadcast_type: BroadcastType<B>, ) -> ReceiverCount

pub fn receiver_count_after_increment<B: BroadcastTypeTrait>( &self, broadcast_type: BroadcastType<B>, ) -> ReceiverCount

pub fn receiver_count_after_decrement<B: BroadcastTypeTrait>( &self, broadcast_type: BroadcastType<B>, ) -> ReceiverCount

pub fn send<T, B>( &self, broadcast_type: BroadcastType<B>, data: T, ) -> BroadcastMapSendResult<Vec<u8>>

where T: Into<Vec<u8>>, B: BroadcastTypeTrait,

pub async fn run<'a, F1, Fut1, F2, Fut2, F3, Fut3, B>( &self, ctx: &Context, buffer_size: usize, broadcast_type: BroadcastType<B>, request_handler: F1, on_sended: F2, on_client_closed: F3, )

where F1: FnSendSyncStatic<Fut1>, Fut1: FutureSendStatic, F2: FnSendSyncStatic<Fut2>, Fut2: FutureSendStatic, F3: FnSendSyncStatic<Fut3>, Fut3: FutureSendStatic, B: BroadcastTypeTrait,