yegor256#575 implement close and skip method on CapinputStream

original-brownbear · Mar 1, 2016 · 3b35a7f · 3b35a7f
1 parent b2ee751
commit 3b35a7f
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 14 deletions.
diff --git a/src/main/java/org/takes/rq/CapInputStream.java b/src/main/java/org/takes/rq/CapInputStream.java
@@ -99,4 +99,14 @@ public int read(final byte[] buf, final int off,
         }
         return readed;
     }
+
+    @Override
+    public long skip(final long num) throws IOException {
+        return this.origin.skip(num);
+    }
+
+    @Override
+    public void close() throws IOException {
+        this.origin.close();
+    }
 }
diff --git a/src/main/java/org/takes/rq/RqMultipart.java b/src/main/java/org/takes/rq/RqMultipart.java
@@ -141,20 +141,12 @@ final class Base extends RqWrap implements RqMultipart {
         public Base(final Request req) throws IOException {
             super(req);
             final InputStream stream = new RqLengthAware(req).body();
-            try {
-                this.body = Channels.newChannel(stream);
-                try {
-                    this.buffer = ByteBuffer.allocate(
-                        // @checkstyle MagicNumberCheck (1 line)
-                        Math.min(8192, stream.available())
-                    );
-                    this.map = this.requests(req);
-                } finally {
-                    this.body.close();
-                }
-            } finally {
-                stream.close();
-            }
+            this.body = Channels.newChannel(stream);
+            this.buffer = ByteBuffer.allocate(
+                // @checkstyle MagicNumberCheck (1 line)
+                Math.min(8192, stream.available())
+            );
+            this.map = this.requests(req);
         }
         @Override
         public Iterable<Request> part(final CharSequence name) {