Struct WebSockets 

pub struct WebSockets<'a> { /* private fields */ }

Implementations

impl<'a> WebSockets<'a>

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

where Callback: FnMut(WebsocketEvent) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>> + Send + Sync + 'a,

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

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

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

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

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