chore: drain fetching transaction events (paradigmxyz#5309)

Arindam2407 · Nov 5, 2023 · 390abf3 · 390abf3
1 parent 2892f02
commit 390abf3
Showing 1 changed file with 10 additions and 11 deletions.
diff --git a/crates/net/network/src/transactions.rs b/crates/net/network/src/transactions.rs
@@ -778,18 +778,17 @@ where
 
         this.update_request_metrics();
 
-        let fetch_event = this.transaction_fetcher.poll(cx);
-        match fetch_event {
-            Poll::Ready(FetchEvent::TransactionsFetched { peer_id, transactions }) => {
-                if let Some(txns) = transactions {
-                    this.import_transactions(peer_id, txns, TransactionSource::Response);
+        // drain fetching transaction events
+        while let Poll::Ready(fetch_event) = this.transaction_fetcher.poll(cx) {
+            match fetch_event {
+                FetchEvent::TransactionsFetched { peer_id, transactions } => {
+                    if let Some(txns) = transactions {
+                        this.import_transactions(peer_id, txns, TransactionSource::Response);
+                    }
+                }
+                FetchEvent::FetchError { peer_id, error } => {
+                    this.on_request_error(peer_id, error);
                 }
-            }
-            Poll::Ready(FetchEvent::FetchError { peer_id, error }) => {
-                this.on_request_error(peer_id, error);
-            }
-            Poll::Pending => {
-                // No event ready at the moment, nothing to do here.
             }
         }