diff --git a/src/main/java/com/rethinkdb/SocketChannelFacade.java b/src/main/java/com/rethinkdb/SocketChannelFacade.java index 0ffa555..0ce340a 100644 --- a/src/main/java/com/rethinkdb/SocketChannelFacade.java +++ b/src/main/java/com/rethinkdb/SocketChannelFacade.java @@ -6,6 +6,7 @@ import java.io.IOException; import java.net.InetSocketAddress; +import java.net.StandardSocketOptions; import java.nio.ByteBuffer; import java.nio.ByteOrder; import java.nio.channels.SocketChannel; @@ -17,6 +18,7 @@ public void connect(String hostname, int port) { try { socketChannel = SocketChannel.open(); socketChannel.configureBlocking(true); + socketChannel.setOption(StandardSocketOptions.TCP_NODELAY, true); socketChannel.connect(new InetSocketAddress(hostname, port)); } catch (IOException e) { throw new RethinkDBException(e);