fix(transport): tcp nodelay option on publisher

chainbound · Jan 19, 2024 · 5dd3d58 · 5dd3d58
1 parent 6b2611f
commit 5dd3d58
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/msg-transport/src/tcp/mod.rs b/msg-transport/src/tcp/mod.rs
@@ -76,7 +76,10 @@ impl Transport for Tcp {
  Poll::Ready(Ok((io, addr))) => {
  tracing::debug!("Accepted connection from {}", addr);
 
- Poll::Ready(Box::pin(async move { Ok(io) }))
+ Poll::Ready(Box::pin(async move {
+ io.set_nodelay(true)?;
+ Ok(io)
+ }))
  }
  Poll::Ready(Err(e)) => Poll::Ready(async_error(e)),
  Poll::Pending => Poll::Pending,