From 8b4aba592cca9c6ce718a273cb3e1362612cd0ff Mon Sep 17 00:00:00 2001
From: Bryan Stitt <bryan@llamanodes.com>
Date: Tue, 22 Aug 2023 10:49:04 -0700
Subject: [PATCH] cargo fmt

---
 web3_proxy/src/rpcs/many.rs | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/web3_proxy/src/rpcs/many.rs b/web3_proxy/src/rpcs/many.rs
index 201161b5..9faeb88b 100644
--- a/web3_proxy/src/rpcs/many.rs
+++ b/web3_proxy/src/rpcs/many.rs
@@ -83,7 +83,8 @@ impl Web3Rpcs {
         Web3ProxyJoinHandle<()>,
         watch::Receiver<Option<Arc<RankedRpcs>>>,
     )> {
-        let (block_and_rpc_sender, block_and_rpc_receiver) = mpsc::unbounded_channel::<BlockAndRpc>();
+        let (block_and_rpc_sender, block_and_rpc_receiver) =
+            mpsc::unbounded_channel::<BlockAndRpc>();
 
         // these blocks don't have full transactions, but they do have rather variable amounts of transaction hashes
         // TODO: actual weighter on this
@@ -348,7 +349,11 @@ impl Web3Rpcs {
 
             let handle = tokio::task::Builder::default()
                 .name("process_incoming_blocks")
-                .spawn(async move { connections.process_incoming_blocks(block_and_rpc_receiver).await })?;
+                .spawn(async move {
+                    connections
+                        .process_incoming_blocks(block_and_rpc_receiver)
+                        .await
+                })?;
 
             futures.push(flatten_handle(handle));
         }