simple request update

blockworks-foundation · Jan 21, 2025 · 05581ba · 05581ba
1 parent 41ac595
commit 05581ba
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/examples/subscribe_accounts.rs b/examples/subscribe_accounts.rs
@@ -66,11 +66,11 @@ pub async fn main() {
     // drop(client_subscribe_tx);
 
     // testcase 2
-    // spawn_subscribe_filter_updater(client_subscribe_tx.clone());
+    spawn_subscribe_filter_updater(client_subscribe_tx.clone());
 
 
     // testcase 3
-    // spawn_subscribe_broken_filter_updater
+    // spawn_subscribe_broken_filter_updater(client_subscribe_tx.clone());
 
     let current_processed_slot = AtomicSlot::default();
     start_tracking_account_consumer(geyser_messages_rx, current_processed_slot.clone());

diff --git a/src/grpc_subscription_autoreconnect_tasks.rs b/src/grpc_subscription_autoreconnect_tasks.rs
@@ -290,10 +290,7 @@ pub fn create_geyser_autoconnection_task_with_mpsc(
                                         subscribe_filter_on_connect = subscribe_request.clone();
                                         // note: if the subscription is invalid, it will trigger a Tonic error:
                                         //  Status { code: InvalidArgument, message: "failed to create filter: Invalid Base58 string", source: None }
-                                        let fut_send = geyser_subscribe_tx.send(subscribe_request);
-                                        let MaybeExit::Continue(send_result) =
-                                            await_or_exit(fut_send, exit_notify.recv()).await
-                                        else {
+                                        if let Err(send_err) = geyser_subscribe_tx.send(subscribe_request).await {
                                             warn!("fail to send subscription update - disconnect and retry");
                                             break 'recv_loop ConnectionState::WaitReconnect(1);
                                         };