Struct atomic_websocket::client_sender::ClientSenders

pub struct ClientSenders { /* private fields */ }

Implementations

impl ClientSenders

pub fn new() -> Self

pub async fn add(&mut self, peer: String, sx: Sender<Message>)

pub fn get_handle_message_receiver(&self) -> Receiver<(Vec<u8>, String)>

pub async fn send_handle_message(&self, data: Vec<u8>, peer: String)

pub fn check_client_send_time(&mut self)

pub fn remove(&mut self, peer: String)

pub async fn send(&mut self, peer: String, message: Message) -> bool