diff --git a/src/main/java/io/grpc/netty/WriteQueue.java b/src/main/java/io/grpc/netty/WriteQueue.java index c3793c32d0..36b078aa8e 100644 --- a/src/main/java/io/grpc/netty/WriteQueue.java +++ b/src/main/java/io/grpc/netty/WriteQueue.java @@ -49,7 +49,7 @@ public class WriteQueue { }; // Dequeue in chunks, so we don't have to acquire the queue's log too often. - @VisibleForTesting static final int DEQUE_CHUNK_SIZE = 128; + @VisibleForTesting static final int DEQUE_CHUNK_SIZE = 2; /** {@link Runnable} used to schedule work onto the tail of the event loop. */ private final Runnable later =