use zenwave::websocket::{self, WebSocketMessage};
fn main() -> Result<(), Box<dyn std::error::Error>> {
async_io::block_on(async {
let socket = websocket::connect("wss://echo.websocket.events").await?;
socket.send_text("hello from zenwave").await?;
if let Some(message) = socket.recv().await? {
match message {
WebSocketMessage::Text(text) => println!("Received text: {text}"),
WebSocketMessage::Binary(bytes) => println!("Received {} bytes", bytes.len()),
WebSocketMessage::Ping(_) => println!("Received ping"),
WebSocketMessage::Pong(_) => println!("Received pong"),
WebSocketMessage::Close => println!("Received close"),
}
} else {
println!("Server closed the connection");
}
socket.close().await?;
Ok(())
})
}