Add non blocking bounded queue FeedableBodyGenerator

slandelle · slandelle · commit 4a0d2d74cf6f · 2015-12-07T23:36:25.000+01:00
diff --git a/client/src/main/java/org/asynchttpclient/request/body/generator/BoundedQueueFeedableBodyGenerator.java b/client/src/main/java/org/asynchttpclient/request/body/generator/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);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -16,15 +16,14 @@`
`16`	`16`	`import java.util.concurrent.ArrayBlockingQueue;`
`17`	`17`	`import java.util.concurrent.BlockingQueue;`
`18`	`18`
`19`		`-public final class BlockingQueueFeedableBodyGenerator extends QueueBasedFeedableBodyGenerator<BlockingQueue<BodyChunk>> {`
	`19`	`+public final class BoundedQueueFeedableBodyGenerator extends QueueBasedFeedableBodyGenerator<BlockingQueue<BodyChunk>> {`
`20`	`20`
`21`		`- public BlockingQueueFeedableBodyGenerator(int capacity) {`
	`21`	`+ public BoundedQueueFeedableBodyGenerator(int capacity) {`
`22`	`22`	`super(new ArrayBlockingQueue<>(capacity, true));`
`23`	`23`	`}`
`24`	`24`
`25`	`25`	`@Override`
`26`	`26`	`protected boolean offer(BodyChunk chunk) throws InterruptedException {`
`27`		`- queue.put(chunk);`
`28`		`- return true;`
	`27`	`+ return queue.offer(chunk);`
`29`	`28`	`}`
`30`	`29`	`}`