From 928b0beb5dca3795a7059c03a600f8fb17e58a25 Mon Sep 17 00:00:00 2001
From: Henry de Valence <hdevalence@hdevalence.ca>
Date: Tue, 21 Jul 2020 15:40:00 -0700
Subject: [PATCH] sync: unindent fetch task

---
 zebrad/src/commands/start/sync.rs | 37 +++++++++++++++----------------
 1 file changed, 18 insertions(+), 19 deletions(-)

diff --git a/zebrad/src/commands/start/sync.rs b/zebrad/src/commands/start/sync.rs
index 02362f5b8..689a3d6ff 100644
--- a/zebrad/src/commands/start/sync.rs
+++ b/zebrad/src/commands/start/sync.rs
@@ -320,26 +320,25 @@ where
             let mut retry_peer_set = self.block_network.clone();
             let mut verifier = self.verifier.clone();
             let span = tracing::info_span!("block_fetch_verify", ?hash);
-            self.pending_blocks.push(
-                tokio::spawn(async move {
-                    let block = match retry_peer_set
-                        .ready_and()
-                        .await?
-                        .call(zn::Request::BlocksByHash(iter::once(hash).collect()))
-                        .await
-                    {
-                        Ok(zn::Response::Blocks(blocks)) => blocks
-                            .into_iter()
-                            .next()
-                            .expect("successful response has the block in it"),
-                        Ok(_) => unreachable!("wrong response to block request"),
-                        Err(e) => return Err(e),
-                    };
+            let task = tokio::spawn(async move {
+                let block = match retry_peer_set
+                    .ready_and()
+                    .await?
+                    .call(zn::Request::BlocksByHash(iter::once(hash).collect()))
+                    .await
+                {
+                    Ok(zn::Response::Blocks(blocks)) => blocks
+                        .into_iter()
+                        .next()
+                        .expect("successful response has the block in it"),
+                    Ok(_) => unreachable!("wrong response to block request"),
+                    Err(e) => return Err(e),
+                };
 
-                    verifier.ready_and().await?.call(block).await
-                })
-                .instrument(span),
-            );
+                verifier.ready_and().await?.call(block).await
+            })
+            .instrument(span);
+            self.pending_blocks.push(task);
         }
 
         Ok(())