# HG changeset patch
# User sugi
# Date 1420784040 -32400
# Node ID 8d782f988d92af405a83e4c1b29595bb6085d18d
# Parent  efe621b1dba9da4ddf97c46a3fb822d79da09fb3
refactor

diff -r efe621b1dba9 -r 8d782f988d92 src/main/java/org/msgpack/io/StreamInput.java
--- a/src/main/java/org/msgpack/io/StreamInput.java	Fri Jan 09 14:19:23 2015 +0900
+++ b/src/main/java/org/msgpack/io/StreamInput.java	Fri Jan 09 15:14:00 2015 +0900
@@ -112,9 +112,4 @@
         in.close();
     }
 
-    public byte[] getRawByteArray(int len) throws IOException {
-        byte[] b = new byte[len];
-        read(b, 0, len);
-        return b;
-    }
 }
diff -r efe621b1dba9 -r 8d782f988d92 src/main/java/org/msgpack/unpacker/MessagePackBufferUnpacker.java
--- a/src/main/java/org/msgpack/unpacker/MessagePackBufferUnpacker.java	Fri Jan 09 14:19:23 2015 +0900
+++ b/src/main/java/org/msgpack/unpacker/MessagePackBufferUnpacker.java	Fri Jan 09 15:14:00 2015 +0900
@@ -22,7 +22,6 @@
 
 import org.msgpack.MessagePack;
 import org.msgpack.io.LinkedBufferInput;
-import org.msgpack.io.StreamInput;
 
 public class MessagePackBufferUnpacker extends MessagePackUnpacker implements BufferUnpacker {
     private static final int DEFAULT_BUFFER_SIZE = 512; // TODO default buffer
@@ -108,6 +107,8 @@
     }
 
     public byte[] getSerializedByteArray(int len) throws IOException {
-        return ((StreamInput)in).getRawByteArray(len);
+        byte[] b = new byte[len];
+        in.read(b, 0, b.length);
+        return b;
     }
 }
diff -r efe621b1dba9 -r 8d782f988d92 src/main/java/org/msgpack/unpacker/MessagePackUnpacker.java
--- a/src/main/java/org/msgpack/unpacker/MessagePackUnpacker.java	Fri Jan 09 14:19:23 2015 +0900
+++ b/src/main/java/org/msgpack/unpacker/MessagePackUnpacker.java	Fri Jan 09 15:14:00 2015 +0900
@@ -684,6 +684,8 @@
     }
 
     public byte[] getSerializedByteArray(int len) throws IOException {
-        return ((StreamInput)in).getRawByteArray(len);
+        byte[] b = new byte[len];
+        in.read(b, 0, b.length);
+        return b;
     }
 }