3838public class DemuxInputStreamTest {
3939
4040 private static class ReaderThread extends Thread {
41- private final StringBuffer stringBuffer = new StringBuffer ();
42- private final InputStream inputStream ;
4341 private final DemuxInputStream demuxInputStream ;
42+ private final InputStream inputStream ;
43+ private final StringBuffer stringBuffer = new StringBuffer ();
4444
4545 ReaderThread (final String name , final InputStream input , final DemuxInputStream demux ) {
4646 super (name );
@@ -74,8 +74,8 @@ public void run() {
7474
7575 private static class WriterThread extends Thread {
7676 private final byte [] byteArray ;
77- private final OutputStream outputStream ;
7877 private final DemuxOutputStream demuxOutputStream ;
78+ private final OutputStream outputStream ;
7979
8080 WriterThread (final String name , final String data , final OutputStream output , final DemuxOutputStream demux ) {
8181 super (name );
@@ -100,17 +100,17 @@ public void run() {
100100 }
101101 }
102102
103- private static final String T1 = "Thread1" ;
104- private static final String T2 = "Thread2" ;
105-
106- private static final String T3 = "Thread3" ;
107- private static final String T4 = "Thread4" ;
103+ private static final Random c_random = new Random ();
108104 private static final String DATA1 = "Data for thread1" ;
109- private static final String DATA2 = "Data for thread2" ;
110105
106+ private static final String DATA2 = "Data for thread2" ;
111107 private static final String DATA3 = "Data for thread3" ;
112108 private static final String DATA4 = "Data for thread4" ;
113- private static final Random c_random = new Random ();
109+ private static final String T1 = "Thread1" ;
110+
111+ private static final String T2 = "Thread2" ;
112+ private static final String T3 = "Thread3" ;
113+ private static final String T4 = "Thread4" ;
114114
115115 private final HashMap <String , ByteArrayOutputStream > outputMap = new HashMap <>();
116116
@@ -187,5 +187,11 @@ public void testOutputStream() throws Exception {
187187 assertEquals (DATA4 , getOutput (T4 ), "Data4" );
188188 }
189189 }
190- }
191190
191+ @ Test
192+ public void testReadEOF () throws Exception {
193+ try (final DemuxInputStream input = new DemuxInputStream ()) {
194+ assertEquals (IOUtils .EOF , input .read ());
195+ }
196+ }
197+ }
0 commit comments