From 6b2611fb9becbe0fdffc3a5a7fda766f6c40a7d6 Mon Sep 17 00:00:00 2001
From: Jonas Bostoen <jonas.bostoen@hotmail.com>
Date: Fri, 19 Jan 2024 16:43:08 +0100
Subject: [PATCH] fix(transport): tcp nodelay option

---
 msg-transport/src/tcp/mod.rs | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/msg-transport/src/tcp/mod.rs b/msg-transport/src/tcp/mod.rs
index 1d6ad3c..c9c9058 100644
--- a/msg-transport/src/tcp/mod.rs
+++ b/msg-transport/src/tcp/mod.rs
@@ -57,7 +57,12 @@ impl Transport for Tcp {
     }
 
     fn connect(&mut self, addr: SocketAddr) -> Self::Connect {
-        Box::pin(TcpStream::connect(addr))
+        Box::pin(async move {
+            let stream = TcpStream::connect(addr).await?;
+            stream.set_nodelay(true)?;
+
+            Ok(stream)
+        })
     }
 
     fn poll_accept(self: std::pin::Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Accept> {