Add non blocking bounded queue FeedableBodyGenerator

AsyncHttpClient · Dec 7, 2015 · 4a0d2d7 · 4a0d2d7
1 parent 1ef6d82
commit 4a0d2d7
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...r/BlockingQueueFeedableBodyGenerator.java → ...or/BoundedQueueFeedableBodyGenerator.java b/...r/BlockingQueueFeedableBodyGenerator.java → ...or/BoundedQueueFeedableBodyGenerator.java
@@ -16,15 +16,14 @@
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
 
-public final class BlockingQueueFeedableBodyGenerator extends QueueBasedFeedableBodyGenerator<BlockingQueue<BodyChunk>> {
+public final class BoundedQueueFeedableBodyGenerator extends QueueBasedFeedableBodyGenerator<BlockingQueue<BodyChunk>> {
 
-    public BlockingQueueFeedableBodyGenerator(int capacity) {
+    public BoundedQueueFeedableBodyGenerator(int capacity) {
         super(new ArrayBlockingQueue<>(capacity, true));
     }
 
     @Override
     protected boolean offer(BodyChunk chunk) throws InterruptedException {
-        queue.put(chunk);
-        return true;
+        return queue.offer(chunk);
     }
 }