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 49c73ef409fa357ac6465f49dc9060853a3352e4 Author: Gary Gregory <gardgreg...@gmail.com> AuthorDate: Mon Jul 25 18:49:16 2022 -0400 Formatting --- .../apache/commons/io/DemuxInputStreamTest.java | 30 ++++++++-------------- 1 file changed, 11 insertions(+), 19 deletions(-) diff --git a/src/test/java/org/apache/commons/io/DemuxInputStreamTest.java b/src/test/java/org/apache/commons/io/DemuxInputStreamTest.java index 668f93cf..3bad1006 100644 --- a/src/test/java/org/apache/commons/io/DemuxInputStreamTest.java +++ b/src/test/java/org/apache/commons/io/DemuxInputStreamTest.java @@ -36,15 +36,13 @@ import org.junit.jupiter.api.Test; * Basic unit tests for the multiplexing streams. */ public class DemuxInputStreamTest { - private static class ReaderThread - extends Thread { + + private static class ReaderThread extends Thread { private final StringBuffer stringBuffer = new StringBuffer(); private final InputStream inputStream; private final DemuxInputStream demuxInputStream; - ReaderThread(final String name, - final InputStream input, - final DemuxInputStream demux) { + ReaderThread(final String name, final InputStream input, final DemuxInputStream demux) { super(name); inputStream = input; demuxInputStream = demux; @@ -61,7 +59,7 @@ public class DemuxInputStreamTest { try { int ch = demuxInputStream.read(); while (-1 != ch) { - //System.out.println( "Reading: " + (char)ch ); + // System.out.println( "Reading: " + (char)ch ); stringBuffer.append((char) ch); final int sleepMillis = Math.abs(c_random.nextInt() % 10); @@ -73,16 +71,13 @@ public class DemuxInputStreamTest { } } } - private static class WriterThread - extends Thread { + + private static class WriterThread extends Thread { private final byte[] byteArray; private final OutputStream outputStream; private final DemuxOutputStream demuxOutputStream; - WriterThread(final String name, - final String data, - final OutputStream output, - final DemuxOutputStream demux) { + WriterThread(final String name, final String data, final OutputStream output, final DemuxOutputStream demux) { super(name); outputStream = output; demuxOutputStream = demux; @@ -94,7 +89,7 @@ public class DemuxInputStreamTest { demuxOutputStream.bindStream(outputStream); for (final byte element : byteArray) { try { - //System.out.println( "Writing: " + (char)byteArray[ i ] ); + // System.out.println( "Writing: " + (char)byteArray[ i ] ); demuxOutputStream.write(element); final int sleepMillis = Math.abs(c_random.nextInt() % 10); TestUtils.sleep(sleepMillis); @@ -104,6 +99,7 @@ public class DemuxInputStreamTest { } } } + private static final String T1 = "Thread1"; private static final String T2 = "Thread2"; @@ -143,17 +139,13 @@ public class DemuxInputStreamTest { return output.toString(StandardCharsets.UTF_8); } - private void startReader(final String name, - final String data, - final DemuxInputStream demux) { + private void startReader(final String name, final String data, final DemuxInputStream demux) { final InputStream input = new StringInputStream(data); final ReaderThread thread = new ReaderThread(name, input, demux); threadMap.put(name, thread); } - private void startWriter(final String name, - final String data, - final DemuxOutputStream demux) { + private void startWriter(final String name, final String data, final DemuxOutputStream demux) { final ByteArrayOutputStream output = new ByteArrayOutputStream(); outputMap.put(name, output); final WriterThread thread = new WriterThread(name, data, output, demux);