Formatting

validator_client/src/block_service.rs

@@ -480,8 +480,7 @@ impl<T: SlotClock + 'static, E: EthSpec> BlockService<T, E> {
         // Try the proposer nodes last, since it's likely that they don't have a
         // great view of attestations on the network.
         let unsigned_block = proposer_fallback
-            .request_proposers_last(
-                |beacon_node| async move {
+            .request_proposers_last(|beacon_node| async move {
                 let _get_timer = metrics::start_timer_vec(
                     &metrics::BLOCK_SERVICE_TIMES,
                     &[metrics::BEACON_BLOCK_HTTP_GET],
@@ -502,8 +501,7 @@ impl<T: SlotClock + 'static, E: EthSpec> BlockService<T, E> {
                         e
                     ))
                 })
-                },
-            )
+            })
             .await?;
 
         self_ref

validator_client/src/duties_service.rs

@@ -740,9 +740,7 @@ async fn poll_beacon_attesters<T: SlotClock + 'static, E: EthSpec>(
         let subscriptions_ref = &subscriptions;
         let subscription_result = duties_service
             .beacon_nodes
-            .request(
-                ApiTopic::Subscriptions,
-                |beacon_node| async move {
+            .request(ApiTopic::Subscriptions, |beacon_node| async move {
                 let _timer = metrics::start_timer_vec(
                     &metrics::DUTIES_SERVICE_TIMES,
                     &[metrics::SUBSCRIPTIONS_HTTP_POST],
@@ -750,8 +748,7 @@ async fn poll_beacon_attesters<T: SlotClock + 'static, E: EthSpec>(
                 beacon_node
                     .post_validator_beacon_committee_subscriptions(subscriptions_ref)
                     .await
-                },
-            )
+            })
             .await;
         if subscription_result.as_ref().is_ok() {
             debug!(