Skip to content

Commit cf82e82

Browse files
committed
added BufferPacker#clear()
1 parent 38221c0 commit cf82e82

File tree

4 files changed

+18
-4
lines changed

4 files changed

+18
-4
lines changed

src/main/java/org/msgpack/io/LinkedBufferOutput.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,12 @@ protected boolean flushBuffer(byte[] b, int off, int len) {
6464
return false;
6565
}
6666

67+
public void clear() {
68+
link.clear();
69+
size = 0;
70+
filled = 0;
71+
}
72+
6773
public void close() {
6874
}
6975
}

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,5 +20,7 @@
2020

2121
public interface BufferPacker extends Packer {
2222
public byte[] toByteArray();
23+
24+
public void clear();
2325
}
2426

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

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,8 +42,11 @@ public JSONBufferPacker(MessagePack msgpack, int bufferSize) {
4242
}
4343

4444
public byte[] toByteArray() {
45-
LinkedBufferOutput bo = (LinkedBufferOutput) out;
46-
return ((LinkedBufferOutput) bo).toByteArray();
45+
return ((LinkedBufferOutput) out).toByteArray();
46+
}
47+
48+
public void clear() {
49+
((LinkedBufferOutput) out).clear();
4750
}
4851
}
4952

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

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,11 @@ public MessagePackBufferPacker(MessagePack msgpack, int bufferSize) {
4141
}
4242

4343
public byte[] toByteArray() {
44-
LinkedBufferOutput bo = (LinkedBufferOutput) out;
45-
return ((LinkedBufferOutput) bo).toByteArray();
44+
return ((LinkedBufferOutput) out).toByteArray();
45+
}
46+
47+
public void clear() {
48+
((LinkedBufferOutput) out).clear();
4649
}
4750
}
4851

0 commit comments

Comments
 (0)