lib/async/redis/client.rb in async-redis-0.5.2 vs lib/async/redis/client.rb in async-redis-0.5.3
- old
+ new
@@ -129,10 +129,11 @@
def connect(**options)
Async::Pool::Controller.wrap(**options) do
peer = @endpoint.connect
- peer.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, 1)
+ # We will manage flushing ourselves:
+ peer.sync = true
stream = IO::Stream.new(peer)
@protocol.client(stream)
end