fix

Author: bkolad

examples/demo-rollup/tests/replica/recovery.rs

@@ -31,27 +31,6 @@ async fn test_db_elected_leader_recovery_replica_keeps_running() {
     let token_id = config_gas_token_id();
     let receiver_addr = random_address();
 
-    let tx = build_transfer_token_tx::<S>(
-        &key_and_address.private_key,
-        token_id,
-        receiver_addr,
-        AMOUNT,
-        0,
-    );
-
-    {
-        let mut event_subscription = replica
-            .api_client()
-            .subscribe_to_events_with_filter("Bank/*")
-            .await
-            .unwrap();
-
-        leader.send_tx_to_sequencer(&tx).await.unwrap();
-        wait_for_all_events_with_timeout(Duration::from_millis(50), 1, &mut event_subscription)
-            .await;
-        drop(event_subscription);
-    }
-
     // Pause only the leader's update_state loop to prevent batch production
     leader.pause_preferred_batches_for_node().await;
 
@@ -100,7 +79,7 @@ async fn test_db_elected_leader_recovery_replica_keeps_running() {
         token_id,
         receiver_addr,
         AMOUNT,
-        1,
+        0,
     );
     leader.send_tx_to_sequencer(&tx).await.unwrap();
 
@@ -110,7 +89,7 @@ async fn test_db_elected_leader_recovery_replica_keeps_running() {
         .await
         .unwrap();
 
-    wait_for_all_events_with_timeout(Duration::from_millis(500), 1, &mut event_subscription).await;
+    wait_for_all_events_with_timeout(Duration::from_millis(500), 0, &mut event_subscription).await;
 
     replica.shutdown().await.unwrap();
     leader.shutdown().await.unwrap();