...

Rexios80 · Jan 23, 2025 · 6dfd5d3 · 6dfd5d3
1 parent 07a607c
commit 6dfd5d3
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/pub_stats_collector/lib/repo/pub_repo.dart b/pub_stats_collector/lib/repo/pub_repo.dart
@@ -37,12 +37,14 @@ class PubRepo {
     final dependentMap = <String, Set<String>>{};
     var fetched = 0;
 
+    // Prevent too many concurrent calls to the pub API
+    final pubQueue = TaskQueue(maxJobs: 100);
     Future<void> fetchPackageData(String package) async {
       final result = await Future.wait([
-        _client.packageScore(package),
-        _client.packagePublisher(package),
-        _client.packageOptions(package),
-        _client.packageInfo(package),
+        pubQueue.add(() => _client.packageScore(package)),
+        pubQueue.add(() => _client.packagePublisher(package)),
+        pubQueue.add(() => _client.packageOptions(package)),
+        pubQueue.add(() => _client.packageInfo(package)),
       ]);
 
       final score = result[0] as PackageScore;