From 25b080128565170d4c37201a296330bce6ef28da Mon Sep 17 00:00:00 2001
From: GroovieGermanikus <groovie@mango.markets>
Date: Thu, 21 Dec 2023 10:50:52 +0100
Subject: [PATCH] cleanup

---
 examples/stream_blocks_mainnet.rs      | 6 ------
 src/grpc_subscription_autoreconnect.rs | 1 -
 2 files changed, 7 deletions(-)

diff --git a/examples/stream_blocks_mainnet.rs b/examples/stream_blocks_mainnet.rs
index 9a58e41..5dec75b 100644
--- a/examples/stream_blocks_mainnet.rs
+++ b/examples/stream_blocks_mainnet.rs
@@ -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],
diff --git a/src/grpc_subscription_autoreconnect.rs b/src/grpc_subscription_autoreconnect.rs
index 897bb4b..fe7c4e0 100644
--- a/src/grpc_subscription_autoreconnect.rs
+++ b/src/grpc_subscription_autoreconnect.rs
@@ -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);