use std::thread; use websocket::Message; use websocket::sync::Server; fn main() { let server = Server::bind("127.0.0.1:1234").unwrap(); for connection in server.filter_map(Result::ok) { // Spawn a new thread for each connection. thread::spawn(move || { let mut client = connection.accept().unwrap(); let message = Message::text("Hello, client!"); let _ = client.send_message(&message); let mess = client.recv_message(); println!("{:#?}", mess); }); } }