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

cleanup

This commit is contained in:
GroovieGermanikus 2023-12-21 10:50:52 +01:00
parent 52546d7662
commit 25b0801285
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
2 changed files with 0 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
examples/stream_blocks_mainnet.rs
View File

@ -145,17 +145,14 @@ pub async fn main() {
let green_stream = create_geyser_reconnecting_stream(
green_config.clone(),
GeyserFilter(CommitmentConfig::confirmed()).blocks_and_txs(),
CommitmentConfig::confirmed(),
);
let blue_stream = create_geyser_reconnecting_stream(
blue_config.clone(),
GeyserFilter(CommitmentConfig::confirmed()).blocks_and_txs(),
CommitmentConfig::confirmed(),
);
let toxiproxy_stream = create_geyser_reconnecting_stream(
toxiproxy_config.clone(),
GeyserFilter(CommitmentConfig::confirmed()).blocks_and_txs(),
CommitmentConfig::confirmed(),
);
let multiplex_stream = create_multiplexed_stream(
vec![green_stream, blue_stream, toxiproxy_stream],
@ -169,17 +166,14 @@ pub async fn main() {
let green_stream = create_geyser_reconnecting_stream(
green_config.clone(),
GeyserFilter(CommitmentConfig::confirmed()).blocks_meta(),
CommitmentConfig::confirmed(),
);
let blue_stream = create_geyser_reconnecting_stream(
blue_config.clone(),
GeyserFilter(CommitmentConfig::confirmed()).blocks_meta(),
CommitmentConfig::confirmed(),
);
let toxiproxy_stream = create_geyser_reconnecting_stream(
toxiproxy_config.clone(),
GeyserFilter(CommitmentConfig::confirmed()).blocks_meta(),
CommitmentConfig::confirmed(),
);
let multiplex_stream = create_multiplexed_stream(
vec![green_stream, blue_stream, toxiproxy_stream],

1
src/grpc_subscription_autoreconnect.rs
View File

@ -166,7 +166,6 @@ fn map_commitment_level(commitment_config: CommitmentConfig) -> CommitmentLevel
pub fn create_geyser_reconnecting_stream(
grpc_source: GrpcSourceConfig,
subscribe_filter: SubscribeRequest,
commitment_config: CommitmentConfig,
) -> impl Stream<Item = Message> {
let mut state = ConnectionState::NotConnected(0);