fix: make record store num_records strictly increasing

getdozer · Oct 3, 2023 · baae32b · baae32b
1 parent 934cd5a
commit baae32b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dozer-recordstore/src/in_memory/store.rs b/dozer-recordstore/src/in_memory/store.rs
@@ -39,7 +39,7 @@ impl ProcessorRecordStore {
     }
 
     pub fn num_records(&self) -> usize {
-        self.inner.read().records.len()
+        self.inner.read().idx
     }
 
     pub fn serialize_slice(&self, start: usize) -> Result<(Vec<u8>, usize), RecordStoreError> {