diff options
Diffstat (limited to 'tests/test_optimistic_transaction_db.rs')
-rw-r--r-- | tests/test_optimistic_transaction_db.rs | 32 |
1 files changed, 19 insertions, 13 deletions
diff --git a/tests/test_optimistic_transaction_db.rs b/tests/test_optimistic_transaction_db.rs index 4ae625a..1d81f2c 100644 --- a/tests/test_optimistic_transaction_db.rs +++ b/tests/test_optimistic_transaction_db.rs @@ -269,13 +269,13 @@ fn iterator_test() { ]; let iter = db.iterator(IteratorMode::Start); - assert_eq!(iter.collect::<Vec<_>>(), expected); + assert_eq!(iter.map(Result::unwrap).collect::<Vec<_>>(), expected); // Test that it's idempotent let iter = db.iterator(IteratorMode::Start); - assert_eq!(iter.collect::<Vec<_>>(), expected); + assert_eq!(iter.map(Result::unwrap).collect::<Vec<_>>(), expected); let iter = db.iterator(IteratorMode::Start); - assert_eq!(iter.collect::<Vec<_>>(), expected); + assert_eq!(iter.map(Result::unwrap).collect::<Vec<_>>(), expected); // Test in reverse let iter = db.iterator(IteratorMode::End); @@ -290,13 +290,16 @@ fn iterator_test() { (k3.clone(), v3.clone()), (k4.clone(), v4.clone()), ]; - assert_eq!(old_iter.collect::<Vec<_>>(), expected); + assert_eq!(old_iter.map(Result::unwrap).collect::<Vec<_>>(), expected); let iter = db.iterator(IteratorMode::Start); - assert_eq!(iter.collect::<Vec<_>>(), expected2); + assert_eq!(iter.map(Result::unwrap).collect::<Vec<_>>(), expected2); let iter = db.iterator(IteratorMode::From(b"k3", Direction::Forward)); - assert_eq!(iter.collect::<Vec<_>>(), vec![(k3, v3), (k4, v4)]); + assert_eq!( + iter.map(Result::unwrap).collect::<Vec<_>>(), + vec![(k3, v3), (k4, v4)] + ); } } @@ -344,7 +347,7 @@ fn prefix_extract_and_iterate_test() { .into_iter() .map(|(k, v)| (k.to_vec().into_boxed_slice(), v.to_vec().into_boxed_slice())) .collect(); - assert_eq!(expected, iter.collect::<Vec<_>>()); + assert_eq!(expected, iter.map(Result::unwrap).collect::<Vec<_>>()); } } @@ -448,13 +451,13 @@ fn transaction_iterator() { let txn = db.transaction(); let iter = txn.iterator(IteratorMode::Start); - assert_eq!(iter.collect::<Vec<_>>(), expected); + assert_eq!(iter.map(Result::unwrap).collect::<Vec<_>>(), expected); // Test that it's idempotent let iter = txn.iterator(IteratorMode::Start); - assert_eq!(iter.collect::<Vec<_>>(), expected); + assert_eq!(iter.map(Result::unwrap).collect::<Vec<_>>(), expected); let iter = txn.iterator(IteratorMode::Start); - assert_eq!(iter.collect::<Vec<_>>(), expected); + assert_eq!(iter.map(Result::unwrap).collect::<Vec<_>>(), expected); // Test in reverse let iter = txn.iterator(IteratorMode::End); @@ -469,13 +472,16 @@ fn transaction_iterator() { (k3.clone(), v3.clone()), (k4.clone(), v4.clone()), ]; - assert_eq!(old_iter.collect::<Vec<_>>(), expected); + assert_eq!(old_iter.map(Result::unwrap).collect::<Vec<_>>(), expected); let iter = txn.iterator(IteratorMode::Start); - assert_eq!(iter.collect::<Vec<_>>(), expected2); + assert_eq!(iter.map(Result::unwrap).collect::<Vec<_>>(), expected2); let iter = txn.iterator(IteratorMode::From(b"k3", Direction::Forward)); - assert_eq!(iter.collect::<Vec<_>>(), vec![(k3, v3), (k4, v4)]); + assert_eq!( + iter.map(Result::unwrap).collect::<Vec<_>>(), + vec![(k3, v3), (k4, v4)] + ); } } |