diff --git a/src/net/channel.rs b/src/net/channel.rs
index 5975ccf26..cfa306604 100644
--- a/src/net/channel.rs
+++ b/src/net/channel.rs
@@ -255,7 +255,7 @@ impl Channel {
         );
 
         let stream = &mut *self.writer.lock().await;
-        let _written = message::send_packet(stream, packet).await?;
+        let _ = message::send_packet(stream, packet).await?;
 
         Ok(())
     }
diff --git a/src/net/message.rs b/src/net/message.rs
index 1b0e831fb..21a2bf623 100644
--- a/src/net/message.rs
+++ b/src/net/message.rs
@@ -155,5 +155,7 @@ pub async fn send_packet<W: AsyncWrite + Unpin + Sized>(
     written += packet.payload.len();
     debug!(target: "net::message", "Sent payload {} bytes", packet.payload.len() as u64);
 
+    stream.flush().await?;
+
     Ok(written)
 }