blockworks-foundation
/
geyser-grpc-connector
mirror of https://github.com/blockworks-foundation/geyser-grpc-connector.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

subscribe to all accounts

This commit is contained in:
GroovieGermanikus 2024-05-10 18:23:16 +02:00
parent f6206641b9
commit 4157779f12
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
examples/bench_geyser_grpc_accounts.rs
View File

@ -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());