actix/examples
1
0
Fork 0
mirror of https://github.com/actix/examples synced 2025-08-20 22:05:45 +02:00
Code Issues Releases Wiki Activity

Fix pinging so client doesn't get dropped automatically after 10 seconds (#52)

Browse Source
This commit is contained in:
Daniel Kavanagh
2018-09-30 14:09:00 -06:00
committed by Douman
parent d8412fb9bb
commit 62a0101c07
3 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -113,6 +113,9 @@ impl StreamHandler<ws::Message, ws::ProtocolError> for WsChatSession {
self.hb = Instant::now(); self.hb = Instant::now();
ctx.pong(&msg); ctx.pong(&msg);
} }
ws::Message::Pong(_) => {
self.hb = Instant::now();
}
ws::Message::Text(text) => { ws::Message::Text(text) => {
let m = text.trim(); let m = text.trim();
// we check for /sss type of messages // we check for /sss type of messages
@@ -183,7 +186,6 @@ impl StreamHandler<ws::Message, ws::ProtocolError> for WsChatSession {
ws::Message::Close(_) => { ws::Message::Close(_) => {
ctx.stop(); ctx.stop();
}, },
_ => (),
} }
} }
} }

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

@@ -119,6 +119,9 @@ impl StreamHandler<ws::Message, ws::ProtocolError> for WsChatSession {
self.hb = Instant::now(); self.hb = Instant::now();
ctx.pong(&msg); ctx.pong(&msg);
} }
ws::Message::Pong(_) => {
self.hb = Instant::now();
}
ws::Message::Text(text) => { ws::Message::Text(text) => {
let m = text.trim(); let m = text.trim();
// we check for /sss type of messages // we check for /sss type of messages
@@ -189,7 +192,6 @@ impl StreamHandler<ws::Message, ws::ProtocolError> for WsChatSession {
ws::Message::Close(_) => { ws::Message::Close(_) => {
ctx.stop(); ctx.stop();
}, },
_ => (),
} }
} }
} }

4
websocket/src/main.rs
View File

@@ -52,12 +52,14 @@ impl StreamHandler<ws::Message, ws::ProtocolError> for MyWebSocket {
self.hb = Instant::now(); self.hb = Instant::now();
ctx.pong(&msg); ctx.pong(&msg);
} }
ws::Message::Pong(_) => {
self.hb = Instant::now();
}
ws::Message::Text(text) => ctx.text(text), ws::Message::Text(text) => ctx.text(text),
ws::Message::Binary(bin) => ctx.binary(bin), ws::Message::Binary(bin) => ctx.binary(bin),
ws::Message::Close(_) => { ws::Message::Close(_) => {
ctx.stop(); ctx.stop();
} }
_ => (),
} }
} }
} }