提交 0f49df20 authored 作者: noelgrandin@gmail.com's avatar noelgrandin@gmail.com

close some streams

上级 c4e24040
...@@ -336,6 +336,7 @@ public class TestConcurrent extends TestMVStore { ...@@ -336,6 +336,7 @@ public class TestConcurrent extends TestMVStore {
s.setReuseSpace(true); s.setReuseSpace(true);
FileOutputStream out = new FileOutputStream(fileNameRestore); FileOutputStream out = new FileOutputStream(fileNameRestore);
out.write(buff); out.write(buff);
out.close();
MVStore s2 = openStore(fileNameRestore); MVStore s2 = openStore(fileNameRestore);
MVMap<Integer, byte[]> test = s2.openMap("test"); MVMap<Integer, byte[]> test = s2.openMap("test");
for (Integer k : test.keySet()) { for (Integer k : test.keySet()) {
......
...@@ -113,6 +113,7 @@ public class TestStreams extends TestBase { ...@@ -113,6 +113,7 @@ public class TestStreams extends TestBase {
j += l; j += l;
} }
} }
decompress.close();
assertEquals(buffer, test); assertEquals(buffer, test);
} }
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论