Keep consistent read size after closing MessageUnpacker (#621)

Author: okumin

msgpack-core/src/main/java/org/msgpack/core/MessageUnpacker.java

@@ -1735,6 +1735,7 @@ private int readNextLength32()
     public void close()
             throws IOException
     {
+        totalReadBytes += position;
         buffer = EMPTY_BUFFER;
         position = 0;
         in.close();

msgpack-core/src/test/scala/org/msgpack/core/MessageUnpackerTest.scala

@@ -254,6 +254,9 @@ class MessageUnpackerTest extends AirSpec with Benchmark {
         }
         count shouldBe 6
         unpacker.getTotalReadBytes shouldBe arr.length
+
+        unpacker.close()
+        unpacker.getTotalReadBytes shouldBe arr.length
       }
     }
 
@@ -268,6 +271,9 @@ class MessageUnpackerTest extends AirSpec with Benchmark {
 
         skipCount shouldBe 2
         unpacker.getTotalReadBytes shouldBe testData.length
+
+        unpacker.close()
+        unpacker.getTotalReadBytes shouldBe testData.length
       }
     }
 
@@ -322,6 +328,9 @@ class MessageUnpackerTest extends AirSpec with Benchmark {
 
         ib.result() shouldBe intSeq.toSeq
         unpacker.getTotalReadBytes shouldBe testData2.length
+
+        unpacker.close()
+        unpacker.getTotalReadBytes shouldBe testData2.length
       }
     }
 
@@ -352,6 +361,9 @@ class MessageUnpackerTest extends AirSpec with Benchmark {
               }
               count shouldBe numElems
               unpacker.getTotalReadBytes shouldBe data.length
+
+              unpacker.close()
+              unpacker.getTotalReadBytes shouldBe data.length
             }
           }
         }
@@ -869,6 +881,9 @@ class MessageUnpackerTest extends AirSpec with Benchmark {
           unpacker.unpackInt shouldBe 1
 
           unpacker.getTotalReadBytes shouldBe arr.length
+
+          unpacker.close()
+          unpacker.getTotalReadBytes shouldBe arr.length
         }
       }
     }