Struct binance::websockets::WebSockets

pub struct WebSockets<'a, WE> {
    pub socket: Option<(WebSocket<AutoStream>, Response)>,
    // some fields omitted
}

Fields

socket: Option<(WebSocket<AutoStream>, Response)>

Implementations

impl<'a, WE: DeserializeOwned> WebSockets<'a, WE>

pub fn new<Callback>(handler: Callback) -> WebSockets<'a, WE> where
    Callback: FnMut(WE) -> Result<()> + 'a, 

New websocket holder with default configuration

Examples

see examples/binance_websockets.rs

pub fn new_with_options<Callback>(
    handler: Callback,
    conf: Config
) -> WebSockets<'a, WE> where
    Callback: FnMut(WE) -> Result<()> + 'a, 

New websocket holder with provided configuration

Examples

see examples/binance_websockets.rs

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

Connect to a websocket endpoint

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

Disconnect from the endpoint

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