Struct WebsocketClient 

pub struct WebsocketClient {
    pub connection: Option<Connection>,
}

Fields

connection: Option<Connection>

Implementations

impl WebsocketClient

pub fn new() -> Self

pub async fn connect( connect_addr: String, ) -> Result<Connection, WebsocketClientError>

pub async fn listen_future( &mut self, conn: Connection, channel: Sender<InboundMessage>, ) -> impl Future<Output = ()> + '_

pub async fn listen( &mut self, conn: Connection, channel: Sender<InboundMessage>, )

pub fn add_connection(&mut self, connection: Connection)

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