Add RepositoryInterface.flush_chunks method

1 files changed, 10 insertions, 0 deletions

diff --git a/obnamlib/repo_interface.py b/obnamlib/repo_interface.py
index b39f8abe..540d1590 100644
--- a/obnamlib/repo_interface.py
+++ b/obnamlib/repo_interface.py
@@ -700,6 +700,10 @@ class RepositoryInterface(object):
         '''Generate all chunk ids in repository.'''
         raise NotImplementedError()
 
+    def flush_chunks(self):
+        '''Flush any pending chunks.'''
+        raise NotImplementedError()
+
     def lock_chunk_indexes(self):
         '''Locks chunk indexes for updates.'''
         raise NotImplementedError()
@@ -1840,6 +1844,12 @@ class RepositoryInterfaceTests(unittest.TestCase): # pragma: no cover
 
     def test_puts_chunk_into_repository(self):
         chunk_id = self.repo.put_chunk_content('foochunk')
+        self.repo.flush_chunks()
+        self.assertTrue(self.repo.has_chunk(chunk_id))
+        self.assertEqual(self.repo.get_chunk_content(chunk_id), 'foochunk')
+
+    def test_finds_put_chunk_in_unflushed_repository(self):
+        chunk_id = self.repo.put_chunk_content('foochunk')
         self.assertTrue(self.repo.has_chunk(chunk_id))
         self.assertEqual(self.repo.get_chunk_content(chunk_id), 'foochunk')