make connect_with_timeout_with_buffers not async

blockworks-foundation · Mar 26, 2024 · 95cde14 · 95cde14
1 parent 7c0ac01
commit 95cde14
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 5 deletions.
diff --git a/src/grpc_subscription_autoreconnect_streams.rs b/src/grpc_subscription_autoreconnect_streams.rs
@@ -55,8 +55,7 @@ pub fn create_geyser_reconnecting_stream(
                                 connect_timeout,
                                 request_timeout,
                                 buffer_config,
-                            )
-                            .await;
+                            );
                             let mut client = connect_result?;
 
                             debug!("Subscribe with filter {:?}", subscribe_filter);

diff --git a/src/grpc_subscription_autoreconnect_tasks.rs b/src/grpc_subscription_autoreconnect_tasks.rs
@@ -86,8 +86,7 @@ pub fn create_geyser_autoconnection_task_with_mpsc(
                         connect_timeout,
                         request_timeout,
                         buffer_config,
-                    )
-                    .await;
+                    );
 
                     match connect_result {
                         Ok(client) => ConnectionState::Connecting(attempt, client),

diff --git a/src/yellowstone_grpc_util.rs b/src/yellowstone_grpc_util.rs
@@ -51,7 +51,7 @@ impl GeyserGrpcClientBufferConfig {
 }
 
 
-pub async fn connect_with_timeout_with_buffers<E, T>(
+pub fn connect_with_timeout_with_buffers<E, T>(
     endpoint: E,
     x_token: Option<T>,
     tls_config: Option<ClientTlsConfig>,