actix/examples
1
0
Fork 0
mirror of https://github.com/actix/examples synced 2024-11-27 16:02:57 +01:00
Code Issues Releases Wiki Activity

send the correct exit code when closing the websocket (#335)

Browse Source 
Signed-off-by: Bart Willems <bwillems@protonmail.com>
This commit is contained in:
Bart Willems 2020-06-25 06:20:27 +02:00 committed by GitHub
parent 5926035d6c
commit 399fbee1e4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
websocket-autobahn/src/main.rs
View File

@ -25,6 +25,10 @@ impl StreamHandler<Result<ws::Message, ws::ProtocolError>> for WebSocket {
ws::Message::Text(text) => ctx.text(text),
ws::Message::Binary(bin) => ctx.binary(bin),
ws::Message::Ping(bytes) => ctx.pong(&bytes),
ws::Message::Close(reason) => {
ctx.close(reason);
ctx.stop();
}
_ => {}
}
} else {

5
websocket-chat-broker/src/session.rs
View File

@ -151,11 +151,10 @@ impl StreamHandler<Result<ws::Message, ws::ProtocolError>> for WsChatSession {
}
self.send_msg(msg);
}
ws::Message::Close(_) => {
ws::Message::Close(reason) => {
ctx.close(reason);
ctx.stop();
}
_ => {}
}
}

3
websocket-chat/src/main.rs
View File

@ -182,7 +182,8 @@ impl StreamHandler<Result<ws::Message, ws::ProtocolError>> for WsChatSession {
}
}
ws::Message::Binary(_) => println!("Unexpected binary"),
ws::Message::Close(_) => {
ws::Message::Close(reason) => {
ctx.close(reason);
ctx.stop();
}
ws::Message::Continuation(_) => {

3
websocket-tcp-chat/src/main.rs
View File

@ -184,7 +184,8 @@ impl StreamHandler<Result<ws::Message, ws::ProtocolError>> for WsChatSession {
}
}
ws::Message::Binary(_) => println!("Unexpected binary"),
ws::Message::Close(_) => {
ws::Message::Close(reason) => {
ctx.close(reason);
ctx.stop();
}
_ => (),

3
websocket/src/main.rs
View File

@ -59,7 +59,8 @@ impl StreamHandler<Result<ws::Message, ws::ProtocolError>> for MyWebSocket {
}
Ok(ws::Message::Text(text)) => ctx.text(text),
Ok(ws::Message::Binary(bin)) => ctx.binary(bin),
Ok(ws::Message::Close(_)) => {
Ok(ws::Message::Close(reason)) => {
ctx.close(reason);
ctx.stop();
}
_ => ctx.stop(),