diff --git a/chain/sync.go b/chain/sync.go
index 03ae1cd4f..74dc5aa1a 100644
--- a/chain/sync.go
+++ b/chain/sync.go
@@ -1486,11 +1486,7 @@ func (syncer *Syncer) iterFullTipsets(ctx context.Context, headers []*types.TipS
 
 		batchSize := concurrentSyncRequests * syncRequestBatchSize
 		if i < batchSize {
-			if i == 0 {
-				batchSize = 1
-			} else {
-				batchSize = i
-			}
+			batchSize = i + 1
 		}
 
 		ss.SetStage(api.StageFetchingMessages)