Struct WebSockets 

pub struct WebSockets<'a> {
    pub socket: Option<(WebSocket<MaybeTlsStream<TcpStream>>, Response)>,
    /* private fields */
}

Fields

socket: Option<(WebSocket<MaybeTlsStream<TcpStream>>, Response)>

Implementations

impl<'a> WebSockets<'a>

pub fn new<Callback>(handler: Callback) -> WebSockets<'a>

where Callback: FnMut(WebsocketEvent) -> Result<()> + 'a,

pub fn connect(&mut self, subscription: &str) -> Result<()>

pub fn connect_with_config( &mut self, subscription: &str, config: &Config, ) -> Result<()>

pub fn connect_multiple_streams(&mut self, endpoints: &[String]) -> Result<()>

pub fn disconnect(&mut self) -> Result<()>

pub fn test_handle_msg(&mut self, msg: &str) -> Result<()>

pub fn handle_msg(&mut self, msg: &str) -> Result<()>

pub fn event_loop(&mut self, running: &AtomicBool) -> Result<()>