garydgregory commented on code in PR #447:
URL: https://github.com/apache/commons-io/pull/447#discussion_r1168065679
##########
src/main/java/org/apache/commons/io/input/QueueInputStream.java:
##########
@@ -57,24 +59,45 @@
*/
public class QueueInputStream extends InputStream {
- private final BlockingQueue<Integer> blockingQueue;
+ final BlockingQueue<Integer> blockingQueue;
/**
- * Constructs a new instance with no limit to its internal buffer size.
+ * Constructs a new instance with no limit to its internal queue size
*/
public QueueInputStream() {
this(new LinkedBlockingQueue<>());
}
/**
- * Constructs a new instance with given buffer
+ * Constructs a new instance with given queue
*
* @param blockingQueue backing queue for the stream
*/
public QueueInputStream(final BlockingQueue<Integer> blockingQueue) {
this.blockingQueue = Objects.requireNonNull(blockingQueue,
"blockingQueue");
}
+ /**
Review Comment:
@maxxedev Hm, let me try something and get back to you...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
