Skip to content

Commit 402abf2

Browse files
added stream writable check
1 parent 922d0df commit 402abf2

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

src/responses/ping.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ pub async fn handle_and_send(stream: &mut TcpStream, buff: &mut BytesMut) -> Res
99
let payload = buff.get_i64();
1010
let packet = PingPacket { payload };
1111

12+
stream.writable().await?;
1213
stream.write_all(&packet.build()?).await?;
1314
Ok(())
1415
}

src/responses/status.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@ pub async fn send(stream: &mut TcpStream, session: &mut Session) -> Result<()> {
2828
enforces_secure_chat: false,
2929
};
3030

31+
stream.writable().await?;
3132
stream
3233
.write_all(&status::StatusPacket::build(data)?)
3334
.await?;

0 commit comments

Comments
 (0)