use log2::*;
use ws2::{Pod, WebSocket};
struct Worker;
impl ws2::Handler for Worker {
fn on_open(&mut self, ws: &WebSocket) -> Pod {
info!("on open: {ws}");
Ok(())
}
fn on_close(&mut self, ws: &WebSocket) -> Pod {
info!("on close: {ws}");
Ok(())
}
fn on_message(&mut self, ws: &WebSocket, msg: String) -> Pod {
info!("on message: {msg}, {ws}");
Ok(())
}
}
fn main() -> Pod {
let _log2 = log2::start();
let url = "wss://stream.binance.com:9443/ws/btcusdt@miniTicker";
let mut client = ws2::connect(url)?;
let mut workder = Worker {};
loop {
let _ = client.process(&mut workder, 0.5);
}
}