From b5ed04efc694c5a0e4f6925b7f90ebaac9f0504f Mon Sep 17 00:00:00 2001 From: "Jad K. Haddad" Date: Mon, 28 Oct 2024 11:30:27 +0100 Subject: [PATCH] fix(send): NetworkConnection::send sends bytes via embedded_io_async::Write::write_all and flush Signed-off-by: Jad K. Haddad --- src/network/mod.rs | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/src/network/mod.rs b/src/network/mod.rs index 0b10a10..6a44e17 100644 --- a/src/network/mod.rs +++ b/src/network/mod.rs @@ -44,11 +44,16 @@ where /// Send the data from `buffer` via TCP connection. pub async fn send(&mut self, buffer: &[u8]) -> Result<(), ReasonCode> { - let _ = self - .io - .write(buffer) + self.io + .write_all(buffer) + .await + .map_err(|_| ReasonCode::NetworkError)?; + + self.io + .flush() .await .map_err(|_| ReasonCode::NetworkError)?; + Ok(()) }