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

fix example with error channel

This commit is contained in:
GroovieGermanikus 2024-06-13 09:44:16 +02:00
parent 3df5431848
commit 9f70e7d7e6
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
examples/stream_blocks_mainnet_task.rs
View File

@ -118,7 +118,7 @@ pub async fn main() {
subscribe_timeout: Duration::from_secs(5),
receive_timeout: Duration::from_secs(5),
};
let (_, exit_notify) = tokio::sync::broadcast::channel(1);
let (exit_send, exit_notify) = tokio::sync::broadcast::channel(1);
let green_config =
GrpcSourceConfig::new(grpc_addr_green, grpc_x_token_green, None, timeouts.clone());
@ -144,7 +144,7 @@ pub async fn main() {
toxiproxy_config.clone(),
GeyserFilter(CommitmentConfig::confirmed()).blocks_meta(),
autoconnect_tx.clone(),
exit_notify,
exit_notify.resubscribe(),
);
start_example_blockmeta_consumer(blockmeta_rx);