ignoring send error during shutdown (#57)

eqlabs · Jan 10, 2024 · 5d99146 · 5d99146
1 parent 1d4ebad
commit 5d99146
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/state-reconstruct-fetcher/src/l1_fetcher.rs b/state-reconstruct-fetcher/src/l1_fetcher.rs
@@ -256,7 +256,15 @@ impl L1Fetcher {
                             }
 
                             if let Some(tx_hash) = log.transaction_hash {
-                                hash_tx.send(tx_hash).await.unwrap();
+                                if let Err(e) = hash_tx.send(tx_hash).await {
+                                    if cancellation_token.is_cancelled() {
+                                        tracing::debug!("Shutting down tx sender...");
+                                        break;
+                                    } else {
+                                        tracing::error!("Cannot send tx hash: {e}");
+                                        continue;
+                                    }
+                                }
                             }
 
                             latest_l2_block_number = new_l2_block_number;