Skip to content

Commit 7b58f04

Browse files
committed
added getBufferSize method in BufferPacker.java
1 parent 3782bac commit 7b58f04

File tree

3 files changed

+12
-8
lines changed

3 files changed

+12
-8
lines changed

src/main/java/org/msgpack/packer/BufferPacker.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,8 @@
2424
* @see {@link org.msgpack.packer.Packer}
2525
*/
2626
public interface BufferPacker extends Packer {
27+
public int getBufferSize();
28+
2729
public byte[] toByteArray();
2830

2931
public void clear();

src/main/java/org/msgpack/packer/MessagePackBufferPacker.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,7 @@
2121
import org.msgpack.io.LinkedBufferOutput;
2222

2323
public class MessagePackBufferPacker extends MessagePackPacker implements BufferPacker {
24-
private static final int DEFAULT_BUFFER_SIZE = 512; // TODO default buffer
25-
// size
24+
private static final int DEFAULT_BUFFER_SIZE = 512;
2625

2726
public MessagePackBufferPacker(MessagePack msgpack) {
2827
this(msgpack, DEFAULT_BUFFER_SIZE);
@@ -32,12 +31,14 @@ public MessagePackBufferPacker(MessagePack msgpack, int bufferSize) {
3231
super(msgpack, new LinkedBufferOutput(bufferSize));
3332
}
3433

35-
@Override
34+
public int getBufferSize() {
35+
return ((LinkedBufferOutput) out).getSize();
36+
}
37+
3638
public byte[] toByteArray() {
3739
return ((LinkedBufferOutput) out).toByteArray();
3840
}
3941

40-
@Override
4142
public void clear() {
4243
reset();
4344
((LinkedBufferOutput) out).clear();

src/main/java/org/msgpack/util/json/JSONBufferPacker.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,7 @@
2222
import org.msgpack.packer.BufferPacker;
2323

2424
public class JSONBufferPacker extends JSONPacker implements BufferPacker {
25-
private static final int DEFAULT_BUFFER_SIZE = 512; // TODO default buffer
26-
// size
25+
private static final int DEFAULT_BUFFER_SIZE = 512; // TODO default buffer size
2726

2827
public JSONBufferPacker() {
2928
this(DEFAULT_BUFFER_SIZE);
@@ -41,12 +40,14 @@ public JSONBufferPacker(MessagePack msgpack, int bufferSize) {
4140
super(msgpack, new LinkedBufferOutput(bufferSize));
4241
}
4342

44-
@Override
43+
public int getBufferSize() {
44+
return ((LinkedBufferOutput) out).getSize();
45+
}
46+
4547
public byte[] toByteArray() {
4648
return ((LinkedBufferOutput) out).toByteArray();
4749
}
4850

49-
@Override
5051
public void clear() {
5152
reset();
5253
((LinkedBufferOutput) out).clear();

0 commit comments

Comments
 (0)