From 4bb315cebcee4cc41312436e534e690a5e0f5aff Mon Sep 17 00:00:00 2001 From: Tdxdxoz Date: Tue, 26 Sep 2023 12:52:05 +0800 Subject: [PATCH] enable TCP_NODELAY for rust client channel --- lib/rs/src/transport/socket.rs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/lib/rs/src/transport/socket.rs b/lib/rs/src/transport/socket.rs index 48d6dda133b..c3e632457e1 100644 --- a/lib/rs/src/transport/socket.rs +++ b/lib/rs/src/transport/socket.rs @@ -52,6 +52,7 @@ use crate::{new_transport_error, TransportErrorKind}; /// use thrift::transport::TTcpChannel; /// /// let stream = TcpStream::connect("127.0.0.1:9189").unwrap(); +/// stream.set_nodelay(true).unwrap(); /// /// // no need to call c.open() since we've already connected above /// let mut c = TTcpChannel::with_stream(stream); @@ -94,6 +95,7 @@ impl TTcpChannel { } else { match TcpStream::connect(&remote_address) { Ok(s) => { + s.set_nodelay(true)?; self.stream = Some(s); Ok(()) }