diff --git a/hbs2-core/lib/HBS2/Actors/Peer.hs b/hbs2-core/lib/HBS2/Actors/Peer.hs
index e481d0a1..3219d29b 100644
--- a/hbs2-core/lib/HBS2/Actors/Peer.hs
+++ b/hbs2-core/lib/HBS2/Actors/Peer.hs
@@ -303,7 +303,7 @@ runPeerM s bus p f  = do
                             <*> liftIO (newTVarIO mempty)
 
   let de = view envDeferred env
-  as <- liftIO $ replicateM 4 $ async $ runPipeline de
+  as <- liftIO $ replicateM 8 $ async $ runPipeline de
 
   sw <- liftIO $ async $ forever $ withPeerM env $ do
           pause defSweepTimeout
diff --git a/hbs2-core/lib/HBS2/Net/Proto/BlockChunks.hs b/hbs2-core/lib/HBS2/Net/Proto/BlockChunks.hs
index a1c4a1fe..5b3378a5 100644
--- a/hbs2-core/lib/HBS2/Net/Proto/BlockChunks.hs
+++ b/hbs2-core/lib/HBS2/Net/Proto/BlockChunks.hs
@@ -84,7 +84,7 @@ blockChunksProto :: forall e m  . ( MonadIO m
 
 blockChunksProto adapter (BlockChunks c p) =
   case p of
-    BlockGetAllChunks h size -> deferred proto do
+    BlockGetAllChunks h size -> do
 
       me <- ownPeer @e
       who <- thatPeer proto
@@ -96,7 +96,7 @@ blockChunksProto adapter (BlockChunks c p) =
         let offsets' = calcChunks bsz (fromIntegral size) :: [(Offset, Size)]
         let offsets = zip offsets' [0..]
 
-        for_ offsets $ \((o,sz),i) -> do
+        for_ offsets $ \((o,sz),i) -> deferred proto do
           chunk <- blkChunk adapter h o sz
           maybe (pure ()) (response_ . BlockChunk @e i) chunk