We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 32b80f6 commit f274d98Copy full SHA for f274d98
lib/rs/src/transport/socket.rs
@@ -52,6 +52,7 @@ use crate::{new_transport_error, TransportErrorKind};
52
/// use thrift::transport::TTcpChannel;
53
///
54
/// let stream = TcpStream::connect("127.0.0.1:9189").unwrap();
55
+/// stream.set_nodelay(true).unwrap();
56
57
/// // no need to call c.open() since we've already connected above
58
/// let mut c = TTcpChannel::with_stream(stream);
@@ -94,6 +95,7 @@ impl TTcpChannel {
94
95
} else {
96
match TcpStream::connect(&remote_address) {
97
Ok(s) => {
98
+ s.set_nodelay(true)?;
99
self.stream = Some(s);
100
Ok(())
101
}
0 commit comments