Struct Connection 

pub struct Connection { /* private fields */ }

Implementations

impl Connection

pub async fn start_listening( resources: Arc<Mutex<ConnectionResources>>, sender_channel: Sender<InboundMessage>, )

pub async fn get_outbound_messages_tx(&self) -> Sender<SocketMessage>

pub async fn listen(&self, sender_channel: Sender<InboundMessage>)

pub async fn get_socket_connection_uuid(&self) -> String

pub async fn clear_pending_reliable_message( pending_reliable_messages: Arc<RwLock<HashMap<String, SocketMessage>>>, message_uuid: String, )

pub async fn forward_inbound_messages( read: SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, sender_channel: Sender<InboundMessage>, socket_connection_uuid: String, outbound_messages_tx: Sender<SocketMessage>, ws_server_events_tx: Sender<WebsocketSystemEvent>, )