OpenSource/axum
OpenSource/axum
1
0
Fork 0
mirror of https://github.com/tokio-rs/axum.git synced 2024-11-21 22:56:46 +01:00
Code Issues Projects Releases Packages Wiki Activity

Expand WebSocket example to match on Message (#723)

Browse source
This commit is contained in:
YuKun Liu 2022-01-25 23:31:33 +08:00 committed by GitHub
parent 32c9ab3c56
commit c0473f2b6f
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
examples/websockets/src/main.rs
View file

@ -75,7 +75,24 @@ async fn ws_handler(
async fn handle_socket(mut socket: WebSocket) {
if let Some(msg) = socket.recv().await {
if let Ok(msg) = msg {
println!("Client says: {:?}", msg);
match msg {
Message::Text(t) => {
println!("client send str: {:?}", t);
}
Message::Binary(_) => {
println!("client send binary data");
}
Message::Ping(_) => {
println!("socket ping");
}
Message::Pong(_) => {
println!("socket pong");
}
Message::Close(_) => {
println!("client disconnected");
return;
}
}
} else {
println!("client disconnected");
return;