2024-05-29 12:44:52 +01:00
|
|
|
use websockets::{WebSocket, WebSocketError};
|
|
|
|
|
|
|
|
|
|
#[tokio::main]
|
|
|
|
|
async fn main() -> Result<(), WebSocketError> {
|
|
|
|
|
let mut ws = WebSocket::connect("ws://localhost:8080/").await?;
|
|
|
|
|
|
|
|
|
|
ws.send_text("foo".to_string()).await?;
|
|
|
|
|
// ws.receive().await?;
|
|
|
|
|
// ws.close(None).await?;
|
|
|
|
|
loop {
|
|
|
|
|
let msg = ws.receive().await?;
|
|
|
|
|
println!("Received: {:?}", msg);
|
|
|
|
|
}
|
2024-05-29 08:32:40 +01:00
|
|
|
}
|