#408 InputStreamOf fixed

yegor256 · Aug 22, 2017 · 7ab6b52 · 7ab6b52
1 parent 9b8822b
commit 7ab6b52
Show file tree

Hide file tree

Showing 4 changed files with 51 additions and 0 deletions.
diff --git a/src/main/java/org/cactoos/io/InputStreamOf.java b/src/main/java/org/cactoos/io/InputStreamOf.java
@@ -255,4 +255,29 @@ public void close() throws IOException {
         this.source.value().close();
     }
 
+    @Override
+    public long skip(final long num) throws IOException {
+        return this.source.value().skip(num);
+    }
+
+    @Override
+    public int available() throws IOException {
+        return this.source.value().available();
+    }
+
+    @Override
+    public void mark(final int limit) {
+        this.source.value().mark(limit);
+    }
+
+    @Override
+    public void reset() throws IOException {
+        this.source.value().reset();
+    }
+
+    @Override
+    public boolean markSupported() {
+        return this.source.value().markSupported();
+    }
+
 }
diff --git a/src/main/java/org/cactoos/io/OutputStreamTo.java b/src/main/java/org/cactoos/io/OutputStreamTo.java
@@ -170,4 +170,9 @@ public void close() throws IOException {
         this.target.value().close();
     }
 
+    @Override
+    public void flush() throws IOException {
+        this.target.value().flush();
+    }
+
 }
diff --git a/src/test/java/org/cactoos/io/InputOfTest.java b/src/test/java/org/cactoos/io/InputOfTest.java
@@ -311,4 +311,14 @@ public void readsAnArrayOfBytes() throws Exception {
         );
     }
 
+    @Test
+    public void makesDataAvailable() throws IOException {
+        final String content = "Hello,חבר!";
+        MatcherAssert.assertThat(
+            "Can't show that data is available",
+            new InputOf(content).stream().available(),
+            Matchers.greaterThan(0)
+        );
+    }
+
 }
diff --git a/src/test/java/org/cactoos/io/InputStreamOfTest.java b/src/test/java/org/cactoos/io/InputStreamOfTest.java
@@ -30,6 +30,7 @@
 import java.nio.file.Path;
 import org.cactoos.InputHasContent;
 import org.hamcrest.MatcherAssert;
+import org.hamcrest.Matchers;
 import org.junit.Test;
 
 /**
@@ -75,4 +76,14 @@ public void readsFromReaderThroughSmallBuffer() {
         );
     }
 
+    @Test
+    public void makesDataAvailable() throws IOException {
+        final String content = "Hello,חבר!";
+        MatcherAssert.assertThat(
+            "Can't show that data is available",
+            new InputStreamOf(content).available(),
+            Matchers.greaterThan(0)
+        );
+    }
+
 }