diff --git a/examples/mvcc.rs b/examples/mvcc.rs index 4499474..46b940f 100644 --- a/examples/mvcc.rs +++ b/examples/mvcc.rs @@ -24,7 +24,10 @@ async fn main() -> Result<(), KernelError> { println!("Read key_1 on the transaction: {:?}", tx.get(b"key_1")?); println!("Set KeyValue on the transaction -> (key_2, value_2)"); - tx.set(Bytes::copy_from_slice(b"key_2"), Bytes::copy_from_slice(b"value_2")); + tx.set( + Bytes::copy_from_slice(b"key_2"), + Bytes::copy_from_slice(b"value_2"), + ); println!("Read key_2 on the transaction: {:?}", tx.get(b"key_2")?); diff --git a/src/kernel/lsm/compactor.rs b/src/kernel/lsm/compactor.rs index e27cd36..43eb9ce 100644 --- a/src/kernel/lsm/compactor.rs +++ b/src/kernel/lsm/compactor.rs @@ -278,7 +278,7 @@ impl Compactor { { let mut iter = table.iter()?; let mut vec_cmd = Vec::with_capacity(table.len()); - while let Some(item) = iter.next_err()? { + while let Some(item) = iter.try_next()? { if fn_is_filter(&item.0) { vec_cmd.push(item) }