From 979cd6e3a46f9a580e670e664c15f95d6379d081 Mon Sep 17 00:00:00 2001
From: eugenp <hanriseldon@gmail.com>
Date: Sun, 13 Jul 2014 21:29:13 +0300
Subject: [PATCH] IO testing work

---
 .../java/io/JavaReaderToXUnitTest.java        | 40 +++++++++++++++++++
 .../java/io/JavaXToReaderUnitTest.java        | 37 +++++++++++++++++
 2 files changed, 77 insertions(+)

diff --git a/core-java/src/test/java/org/baeldung/java/io/JavaReaderToXUnitTest.java b/core-java/src/test/java/org/baeldung/java/io/JavaReaderToXUnitTest.java
index 3d9cdd8a2e..7cb9276283 100644
--- a/core-java/src/test/java/org/baeldung/java/io/JavaReaderToXUnitTest.java
+++ b/core-java/src/test/java/org/baeldung/java/io/JavaReaderToXUnitTest.java
@@ -1,9 +1,11 @@
 package org.baeldung.java.io;
 
+import java.io.ByteArrayInputStream;
 import java.io.File;
 import java.io.FileReader;
 import java.io.FileWriter;
 import java.io.IOException;
+import java.io.InputStream;
 import java.io.Reader;
 import java.io.StringReader;
 import java.io.Writer;
@@ -143,4 +145,42 @@ public class JavaReaderToXUnitTest {
         initialReader.close();
     }
 
+    // tests - Reader to InputStream
+
+    @Test
+    public void givenUsingPlainJava_whenConvertingReaderIntoInputStream_thenCorrect() throws IOException {
+        final Reader initialReader = new StringReader("With Java");
+
+        final char[] charBuffer = new char[8 * 1024];
+        final StringBuilder builder = new StringBuilder();
+        int numCharsRead;
+        while ((numCharsRead = initialReader.read(charBuffer, 0, charBuffer.length)) != -1) {
+            builder.append(charBuffer, 0, numCharsRead);
+        }
+        final InputStream targetStream = new ByteArrayInputStream(builder.toString().getBytes());
+
+        initialReader.close();
+        targetStream.close();
+    }
+
+    @Test
+    public void givenUsingGuava_whenConvertingReaderIntoInputStream_thenCorrect() throws IOException {
+        final Reader initialReader = new StringReader("With Guava");
+
+        final InputStream targetStream = new ByteArrayInputStream(CharStreams.toString(initialReader).getBytes());
+
+        initialReader.close();
+        targetStream.close();
+    }
+
+    @Test
+    public void givenUsingCommonsIO_whenConvertingReaderIntoInputStream() throws IOException {
+        final Reader initialReader = new StringReader("With Commons IO");
+
+        final InputStream targetStream = IOUtils.toInputStream(initialReader.toString());
+
+        initialReader.close();
+        targetStream.close();
+    }
+
 }
diff --git a/core-java/src/test/java/org/baeldung/java/io/JavaXToReaderUnitTest.java b/core-java/src/test/java/org/baeldung/java/io/JavaXToReaderUnitTest.java
index 0d9f6d1f06..42ecef4086 100644
--- a/core-java/src/test/java/org/baeldung/java/io/JavaXToReaderUnitTest.java
+++ b/core-java/src/test/java/org/baeldung/java/io/JavaXToReaderUnitTest.java
@@ -1,18 +1,24 @@
 package org.baeldung.java.io;
 
+import java.io.ByteArrayInputStream;
 import java.io.File;
 import java.io.FileReader;
 import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
 import java.io.Reader;
 import java.io.StringReader;
 import java.nio.charset.Charset;
 
 import org.apache.commons.io.FileUtils;
+import org.apache.commons.io.IOUtils;
 import org.apache.commons.io.input.CharSequenceReader;
 import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.google.common.io.ByteSource;
+import com.google.common.io.ByteStreams;
 import com.google.common.io.CharSource;
 
 public class JavaXToReaderUnitTest {
@@ -94,4 +100,35 @@ public class JavaXToReaderUnitTest {
         targetReader.close();
     }
 
+    // tests - InputStream to Reader
+
+    @Test
+    public void givenUsingPlainJava_whenConvertingInputStreamIntoReader_thenCorrect() throws IOException {
+        final InputStream initialStream = new ByteArrayInputStream("With Java".getBytes());
+        final Reader targetReader = new InputStreamReader(initialStream);
+
+        initialStream.close();
+        targetReader.close();
+    }
+
+    @Test
+    public void givenUsingGuava_whenConvertingInputStreamIntoReader_thenCorrect() throws IOException {
+        final InputStream initialStream = ByteSource.wrap("With Guava".getBytes()).openStream();
+        final byte[] buffer = ByteStreams.toByteArray(initialStream);
+        final Reader targetReader = CharSource.wrap(new String(buffer)).openStream();
+
+        initialStream.close();
+        targetReader.close();
+    }
+
+    @Test
+    public void givenUsingCommonsIO_whenConvertingInputStreamIntoReader_thenCorrect() throws IOException {
+        final InputStream initialStream = IOUtils.toInputStream("With Commons IO");
+        final byte[] buffer = IOUtils.toByteArray(initialStream);
+        final Reader targetReader = new CharSequenceReader(new String(buffer));
+
+        initialStream.close();
+        targetReader.close();
+    }
+
 }