Skip to content

Commit

Permalink
subscribe to all accounts
Browse files Browse the repository at this point in the history
  • Loading branch information
grooviegermanikus committed May 10, 2024
1 parent f620664 commit 4157779
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions examples/bench_geyser_grpc_accounts.rs
Original file line number Diff line number Diff line change
Expand Up @@ -68,20 +68,20 @@ pub async fn main() {
// exit_notify.resubscribe(),
// );

// let _all_accounts = create_geyser_autoconnection_task_with_mpsc(
// config.clone(),
// all_accounts(),
// autoconnect_tx.clone(),
// exit_notify.resubscribe(),
// );

let _token_accounts_task = create_geyser_autoconnection_task_with_mpsc(
let _all_accounts = create_geyser_autoconnection_task_with_mpsc(
config.clone(),
token_accounts(),
all_accounts(),
autoconnect_tx.clone(),
exit_notify.resubscribe(),
);

// let _token_accounts_task = create_geyser_autoconnection_task_with_mpsc(
// config.clone(),
// token_accounts(),
// autoconnect_tx.clone(),
// exit_notify.resubscribe(),
// );

let current_processed_slot = AtomicSlot::default();
start_tracking_slots(current_processed_slot.clone());
start_tracking_account_consumer(geyser_messages_rx, current_processed_slot.clone());
Expand Down

0 comments on commit 4157779

Please sign in to comment.