Mercurial > hg > Members > sugi > MessagePack-java
comparison src/test/java/org/msgpack/unpacker/TestUnpackerIterator.java @ 0:cb825acd883a
first commit
author | sugi |
---|---|
date | Sat, 18 Oct 2014 15:06:15 +0900 |
parents | |
children |
comparison
equal
deleted
inserted
replaced
-1:000000000000 | 0:cb825acd883a |
---|---|
1 package org.msgpack.unpacker; | |
2 | |
3 import static org.junit.Assert.assertEquals; | |
4 | |
5 import java.io.ByteArrayInputStream; | |
6 import java.io.ByteArrayOutputStream; | |
7 | |
8 import org.junit.Test; | |
9 import org.msgpack.MessagePack; | |
10 import org.msgpack.packer.Packer; | |
11 | |
12 public class TestUnpackerIterator { | |
13 | |
14 @Test | |
15 public void testSample() throws Exception { | |
16 MessagePack msgpack = new MessagePack(); | |
17 | |
18 ByteArrayOutputStream out = new ByteArrayOutputStream(); | |
19 Packer packer = msgpack.createPacker(out); | |
20 packer.write(1); | |
21 packer.write(2); | |
22 packer.write(3); | |
23 byte[] bytes = out.toByteArray(); | |
24 | |
25 Unpacker unpacker = msgpack.createUnpacker( | |
26 new ByteArrayInputStream(bytes)); | |
27 UnpackerIterator iter = unpacker.iterator(); | |
28 unpacker.resetReadByteCount(); | |
29 iter.hasNext(); | |
30 iter.next(); | |
31 assertEquals(1, unpacker.getReadByteCount()); | |
32 unpacker.resetReadByteCount(); | |
33 iter.hasNext(); | |
34 iter.next(); | |
35 assertEquals(1, unpacker.getReadByteCount()); | |
36 unpacker.resetReadByteCount(); | |
37 iter.hasNext(); | |
38 iter.next(); | |
39 assertEquals(1, unpacker.getReadByteCount()); | |
40 } | |
41 } |