fmt and clippy

blockworks-foundation · Sep 26, 2023 · e98fc18 · e98fc18
1 parent a84db9f
commit e98fc18
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/cluster-endpoints/src/grpc_subscription.rs b/cluster-endpoints/src/grpc_subscription.rs
@@ -380,14 +380,10 @@ pub fn create_grpc_subscription(
     let block_finalized_task: AnyhowJoinHandle =
         create_block_processing_task(grpc_addr, block_sx, CommitmentLevel::Finalized);
 
-    let mut endpoint_tasks = vec![
-        slot_task,
-        block_confirmed_task,
-        block_finalized_task,
-    ];
+    let mut endpoint_tasks = vec![slot_task, block_confirmed_task, block_finalized_task];
     if let Some(rpc_client) = rpc_client {
         let cluster_info_polling =
-        poll_vote_accounts_and_cluster_info(rpc_client, cluster_info_sx, va_sx);
+            poll_vote_accounts_and_cluster_info(rpc_client, cluster_info_sx, va_sx);
         endpoint_tasks.push(cluster_info_polling);
     }
 

diff --git a/lite-rpc/src/main.rs b/lite-rpc/src/main.rs
@@ -108,7 +108,11 @@ pub async fn start_lite_rpc(args: Args, rpc_client: Arc<RpcClient>) -> anyhow::R
     let tpu_connection_path = configure_tpu_connection_path(quic_proxy_addr);
 
     let (subscriptions, cluster_endpoint_tasks) = if use_grpc {
-        create_grpc_subscription(Some(rpc_client.clone()), grpc_addr, GRPC_VERSION.to_string())?
+        create_grpc_subscription(
+            Some(rpc_client.clone()),
+            grpc_addr,
+            GRPC_VERSION.to_string(),
+        )?
     } else if multiplex_rpc_grpc {
         let (rpc_subscription, mut rpc_tasks) =
             create_json_rpc_polling_subscription(rpc_client.clone())?;