removed Packer.flush

Author: frsyuki

src/main/java/org/msgpack/MessagePack.java

@@ -60,7 +60,6 @@ public void pack(OutputStream out, Object v) throws IOException {
  public void pack(OutputStream out, Object v, Template tmpl) throws IOException {
  StreamPacker pk = new StreamPacker(out);
  tmpl.write(pk, v);
- pk.flush();
  }
 
  public byte[] pack(Value v) throws IOException { // TODO IOException

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

@@ -45,7 +45,5 @@ public interface Output {
  public void writeByteAndFloat(byte b, float v) throws IOException;
 
  public void writeByteAndDouble(byte b, double v) throws IOException;
-
- public void flush() throws IOException;
 }
 

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

@@ -32,11 +32,6 @@ protected AbstractMessagePackPacker(Output out) {
  this.out = out;
  }
 
- @Override
- public void flush() throws IOException {
- out.flush();
- }
-
  @Override
  public void writeByte(byte d) throws IOException {
  if(d < -(1<<5)) {

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

@@ -76,9 +76,6 @@ public void write(MessagePackable v) throws IOException {
  v.writeTo(this);
  }
 
- public void flush() throws IOException {
- }
-
  /* TODO
  public void write(boolean v) throws IOException {
  writeBoolean(v);

src/test/java/org/msgpack/TestCrossLang.java

@@ -78,8 +78,6 @@ public void testCompactSerialize() throws IOException {
  pk.write(av);
  }
 
- pk.flush();
-
  byte[] c = out.toByteArray();
 
  assertEquals(b.length, c.length);

src/test/java/org/msgpack/TestStreamPackUnpack.java

@@ -19,7 +19,6 @@ public void testBoolean(boolean v) throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeBoolean(v);
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 boolean ret = unpacker.readBoolean();
@@ -31,7 +30,6 @@ public void testByte(byte v) throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeByte(v);
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 byte ret = unpacker.readByte();
@@ -43,7 +41,6 @@ public void testShort(short v) throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeShort(v);
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 short ret = unpacker.readShort();
@@ -55,7 +52,6 @@ public void testInt(int v) throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeInt(v);
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 int ret = unpacker.readInt();
@@ -67,7 +63,6 @@ public void testLong(long v) throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeLong(v);
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 long ret = unpacker.readLong();
@@ -79,7 +74,6 @@ public void testFloat(float v) throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeFloat(v);
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 float ret = unpacker.readFloat();
@@ -91,7 +85,6 @@ public void testDouble(double v) throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeDouble(v);
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 double ret = unpacker.readDouble();
@@ -103,7 +96,6 @@ public void testNil() throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeNil();
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 unpacker.readNil();
@@ -114,7 +106,6 @@ public void testBigInteger(BigInteger v) throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeBigInteger(v);
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 BigInteger ret = unpacker.readBigInteger();
@@ -126,7 +117,6 @@ public void testString(String v) throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeString(v);
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 String ret = unpacker.readString();
@@ -138,7 +128,6 @@ public void testByteArray(byte[] v) throws Exception {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 StreamPacker packer = new StreamPacker(out);
 packer.writeByteArray(v);
-packer.flush();
 ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
 StreamUnpacker unpacker = new StreamUnpacker(in);
 byte[] ret = unpacker.readByteArray();