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