in computer-test/src/main/java/org/apache/hugegraph/computer/core/io/BufferedStreamTest.java [302:350]
public void testSkip() throws IOException {
File file = createTempFile();
try {
try (BufferedStreamOutput output = createOutput(file)) {
for (int i = -128; i <= 127; i++) {
output.writeByte(i);
}
output.skip(4L);
output.writeByte(127);
output.skip(1280L);
for (int i = 1; i <= 1280; i++) {
output.writeByte(i);
}
}
try (DataInputStream dis = new DataInputStream(
new FileInputStream(file))) {
Assert.assertEquals(-128, dis.readByte());
dis.skip(1);
for (int i = -126; i <= 127; i++) {
Assert.assertEquals(i, dis.readByte());
}
long count1 = dis.skip(4);
Assert.assertEquals(4, count1);
Assert.assertEquals(127, dis.readByte());
long count2 = dis.skip(1280);
Assert.assertEquals(1280, count2);
for (int i = 1; i <= 1280; i++) {
Assert.assertEquals((byte) i, dis.readByte());
}
}
try (BufferedStreamInput input = createInput(file)) {
Assert.assertEquals(-128, input.readByte());
input.skip(1);
for (int i = -126; i <= 127; i++) {
Assert.assertEquals(i, input.readByte());
}
input.skip(4);
Assert.assertEquals(127, input.readByte());
input.skip(1280);
for (int i = 1; i <= 1280; i++) {
Assert.assertEquals((byte) i, input.readByte());
}
}
} finally {
FileUtils.deleteQuietly(file);
}
}