fix(commit_store): fix skip_while_next warning on get_batch_by_transa…

…ction Signed-off-by: Joseph Livesey <[email protected]>
blockchaintp · Mar 3, 2023 · a767aec · a767aec
1 parent 0fa9094
commit a767aec
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/validator/src/journal/commit_store.rs b/validator/src/journal/commit_store.rs
@@ -332,13 +332,12 @@ impl CommitStore {
                 block
                     .batches
                     .into_iter()
-                    .skip_while(|batch| {
+                    .find(|batch| {
                         batch
                             .transaction_ids
                             .iter()
-                            .all(|txn_id| txn_id != transaction_id)
+                            .any(|txn_id| txn_id == transaction_id)
                     })
-                    .next()
                     .ok_or_else(|| {
                         DatabaseError::CorruptionError("Transaction index corrupted".into())
                     })
@@ -616,13 +615,12 @@ mod tests {
         block
             .batches
             .into_iter()
-            .skip_while(|batch| {
+            .find(|batch| {
                 batch
                     .transaction_ids
                     .iter()
-                    .all(|txn_id| txn_id != transaction_id)
+                    .any(|txn_id| txn_id == transaction_id)
             })
-            .next()
             .ok_or_else(|| DatabaseError::CorruptionError("Transaction index corrupted".into()))
         // })
     }