# HG changeset patch # User sugi # Date 1420780330 -32400 # Node ID d5cc3aef5b74006be9e2f239f6ab70095a80fb22 # Parent e11de4397136519e1c6602ba0bb642280b38ae5d add getSerializedByteArray Method diff -r e11de4397136 -r d5cc3aef5b74 src/main/java/org/msgpack/unpacker/MessagePackBufferUnpacker.java --- a/src/main/java/org/msgpack/unpacker/MessagePackBufferUnpacker.java Sat Oct 18 22:20:05 2014 +0900 +++ b/src/main/java/org/msgpack/unpacker/MessagePackBufferUnpacker.java Fri Jan 09 14:12:10 2015 +0900 @@ -17,10 +17,12 @@ // package org.msgpack.unpacker; +import java.io.IOException; import java.nio.ByteBuffer; 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 @@ -104,4 +106,8 @@ ((LinkedBufferInput) in).clear(); reset(); } + + public byte[] getSerializedByteArray(int len) throws IOException { + return ((StreamInput)in).getRawByteArray(len); + } } diff -r e11de4397136 -r d5cc3aef5b74 src/main/java/org/msgpack/unpacker/MessagePackUnpacker.java --- a/src/main/java/org/msgpack/unpacker/MessagePackUnpacker.java Sat Oct 18 22:20:05 2014 +0900 +++ b/src/main/java/org/msgpack/unpacker/MessagePackUnpacker.java Fri Jan 09 14:12:10 2015 +0900 @@ -682,8 +682,9 @@ public void resetReadByteCount() { in.resetReadByteCount(); } - + public byte[] getSerializedByteArray(int len) throws IOException { + byte b = getHeadByte(); return ((StreamInput)in).getRawByteArray(len); } }