Skip to content
This repository has been archived by the owner on Aug 4, 2024. It is now read-only.

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
KKould committed Sep 10, 2023
1 parent 831447d commit 87cc4da
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 2 deletions.
5 changes: 4 additions & 1 deletion examples/mvcc.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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")?);

Expand Down
2 changes: 1 addition & 1 deletion src/kernel/lsm/compactor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
Expand Down

0 comments on commit 87cc4da

Please sign in to comment.