Following test fails:
def testLargeData : Array[Byte] = {
val out = new ByteArrayOutputStream()
val packer = msgpack.newPacker(out)
val stringLength = 8193
packer
.packArrayHeader(2)
.packString("l" * stringLength)
.packInt(1)
packer.close()
val arr = out.toByteArray
debug(s"packed: ${toHex(arr)}, size:${arr.length}")
arr
}
"parse message large packed data" taggedAs("unpack") in {
val arr = testLargeData
val unpacker = msgpack.newUnpacker(arr)
var count = 0
while(unpacker.hasNext) {
count += 1
readValue(unpacker)
}
count shouldBe 3
unpacker.getTotalReadBytes shouldBe arr.length
}
If stringLength is 8192, the test passes.
Reactions are currently unavailable
Following test fails:
def testLargeData : Array[Byte] = { val out = new ByteArrayOutputStream() val packer = msgpack.newPacker(out) val stringLength = 8193 packer .packArrayHeader(2) .packString("l" * stringLength) .packInt(1) packer.close() val arr = out.toByteArray debug(s"packed: ${toHex(arr)}, size:${arr.length}") arr }"parse message large packed data" taggedAs("unpack") in { val arr = testLargeData val unpacker = msgpack.newUnpacker(arr) var count = 0 while(unpacker.hasNext) { count += 1 readValue(unpacker) } count shouldBe 3 unpacker.getTotalReadBytes shouldBe arr.length }If stringLength is 8192, the test passes.