Loop batches sequentially instead of Promise.all()

ChainSafe · Jun 28, 2021 · 3ce3cf6 · 3ce3cf6
1 parent 4705616
commit 3ce3cf6
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/packages/validator/src/services/indices.ts b/packages/validator/src/services/indices.ts
@@ -62,12 +62,11 @@ export class IndicesService {
     const pubkeysHex = pubkeysToPoll.map((pubkey) => toHexString(pubkey)).slice(0, MAX_PUBKEYS_PER_POLL);
     const batches = pubkeysToBatches(pubkeysHex);
 
-    const newIndicesArr = await Promise.all(
-      batches.map(async (batch) => {
-        const validatorIndicesArr = await Promise.all(batch.map(this.getIndicesPerHttpRequest));
-        return validatorIndicesArr.flat();
-      })
-    );
+    const newIndicesArr = [];
+    for (const batch of batches) {
+      const validatorIndicesArr = await Promise.all(batch.map(this.getIndicesPerHttpRequest));
+      newIndicesArr.push(...validatorIndicesArr.flat());
+    }
     const newIndices = newIndicesArr.flat();
     this.logger.info("Discovered new validators", {count: newIndices.length});
     return newIndices;