This is an automated email from the ASF dual-hosted git repository. ggregory pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/commons-io.git
commit 920a132460afa733fde62f0380f66391c4b305d2 Author: Gary Gregory <[email protected]> AuthorDate: Wed May 3 08:56:25 2023 -0400 Use builder and deprecate old ctor --- src/main/java/org/apache/commons/io/input/QueueInputStream.java | 2 ++ src/main/java/org/apache/commons/io/output/QueueOutputStream.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/org/apache/commons/io/input/QueueInputStream.java b/src/main/java/org/apache/commons/io/input/QueueInputStream.java index 6019ab55..9f851267 100644 --- a/src/main/java/org/apache/commons/io/input/QueueInputStream.java +++ b/src/main/java/org/apache/commons/io/input/QueueInputStream.java @@ -137,7 +137,9 @@ public class QueueInputStream extends InputStream { * Constructs a new instance with given queue and zero timeout. * * @param blockingQueue backing queue for the stream. + * @deprecated Use {@link #builder()}. */ + @Deprecated public QueueInputStream(final BlockingQueue<Integer> blockingQueue) { this(blockingQueue, Duration.ZERO); } diff --git a/src/main/java/org/apache/commons/io/output/QueueOutputStream.java b/src/main/java/org/apache/commons/io/output/QueueOutputStream.java index 0eb648b2..4281aec3 100644 --- a/src/main/java/org/apache/commons/io/output/QueueOutputStream.java +++ b/src/main/java/org/apache/commons/io/output/QueueOutputStream.java @@ -80,7 +80,7 @@ public class QueueOutputStream extends OutputStream { * @return QueueInputStream connected to this stream */ public QueueInputStream newQueueInputStream() { - return new QueueInputStream(blockingQueue); + return QueueInputStream.builder().setBlockingQueue(blockingQueue).get(); } /**
