From 4adfb752109ad3617455e3092ca63852ec74e06a Mon Sep 17 00:00:00 2001
From: Kai Yuan <kent.yuan@Gmail.com>
Date: Sat, 13 May 2023 17:09:08 +0200
Subject: [PATCH] [os-to-is] Convert an OutputStream to an InputStream (#13992)

---
 ...vertOutputStreamToInputStreamUnitTest.java | 53 +++++++++++++++++++
 1 file changed, 53 insertions(+)
 create mode 100644 core-java-modules/core-java-io-conversions-2/src/test/java/com/baeldung/outputstreamtoinputstream/ConvertOutputStreamToInputStreamUnitTest.java

diff --git a/core-java-modules/core-java-io-conversions-2/src/test/java/com/baeldung/outputstreamtoinputstream/ConvertOutputStreamToInputStreamUnitTest.java b/core-java-modules/core-java-io-conversions-2/src/test/java/com/baeldung/outputstreamtoinputstream/ConvertOutputStreamToInputStreamUnitTest.java
new file mode 100644
index 0000000000..53e9da6dbb
--- /dev/null
+++ b/core-java-modules/core-java-io-conversions-2/src/test/java/com/baeldung/outputstreamtoinputstream/ConvertOutputStreamToInputStreamUnitTest.java
@@ -0,0 +1,53 @@
+package com.baeldung.outputstreamtoinputstream;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+
+import org.junit.jupiter.api.Test;
+
+public class ConvertOutputStreamToInputStreamUnitTest {
+
+    @Test
+    void whenUsingByteArray_thenGetExpectedInputStream() throws IOException {
+        String content = "I'm an important message.";
+        try (ByteArrayOutputStream out = new ByteArrayOutputStream()) {
+            out.write(content.getBytes());
+            try (ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray())) {
+                String inContent = new String(in.readAllBytes());
+
+                assertEquals(content, inContent);
+            }
+        }
+    }
+
+    @Test
+    void whenUsingPipeStream_thenGetExpectedInputStream() throws IOException {
+        String content = "I'm going through the pipe.";
+
+        ByteArrayOutputStream originOut = new ByteArrayOutputStream();
+        originOut.write(content.getBytes());
+
+        //connect the pipe
+        PipedInputStream in = new PipedInputStream();
+        PipedOutputStream out = new PipedOutputStream(in);
+
+        try (in) {
+            new Thread(() -> {
+                try (out) {
+                    originOut.writeTo(out);
+                } catch (IOException iox) {
+                    // handle IOExceptions
+                }
+            }).start();
+
+            String inContent = new String(in.readAllBytes());
+            assertEquals(content, inContent);
+        }
+    }
+
+}
\ No newline at end of file