Merge pull request #38 from upserve/add_flush_to_object_store

expose AppendOnlyStore.flush() in AppendOnlyObjectStore

src/main/java/com/upserve/uppend/AppendOnlyObjectStore.java

@@ -1,5 +1,6 @@
 package com.upserve.uppend;
 
+import java.io.*;
 import java.util.function.*;
 import java.util.stream.Stream;
 
@@ -8,7 +9,7 @@
  * convenience typed-access to the deserialized form in an append-only
  * multi-map.
  */
-public class AppendOnlyObjectStore<T> implements AutoCloseable {
+public class AppendOnlyObjectStore<T> implements AutoCloseable, Flushable {
     private final AppendOnlyStore store;
     private final Function<T, byte[]> serializer;
     private final Function<byte[], T> deserializer;
@@ -82,4 +83,9 @@ public void clear() {
     public void close() throws Exception {
         store.close();
     }
-}
+
+    @Override
+    public void flush() throws IOException {
+        store.flush();
+    }
+}

src/test/java/com/upserve/uppend/AppendOnlyObjectStoreTest.java

@@ -78,6 +78,12 @@ public void testClear() {
         verify(store).clear();
     }
 
+    @Test
+    public void testFlush() throws Exception {
+        instance.flush();
+        verify(store).flush();
+    }
+
     @Test
     public void testClose() throws Exception {
         instance.close();