Run methods on each AnalyticsVendor in parallel

grahamsmith · Aug 23, 2021 · 3851d93 · 3851d93
1 parent 32d8a75
commit 3851d93
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/lib/analytics_x.dart b/lib/analytics_x.dart
@@ -16,24 +16,21 @@ class AnalyticsX {
   AnalyticsX._internal();
 
   Future<void> init(List<AnalyticsVendor> vendors) async {
-    final newVendors = List.from(vendors).toSet().difference(_vendors.toSet()).toList();
+    final newVendors = List<AnalyticsVendor>.from(vendors)..removeWhere((v) => _vendors.contains(v));
+
     if (newVendors.isEmpty) {
       return;
     }
 
-    for (final vendor in newVendors) {
-      await vendor.init();
-    }
+    await Future.wait(newVendors.map((vendor) => vendor.init())); //Do all the inits in parallel
 
     _vendors.addAll(List.from(newVendors));
   }
 
   Future<void> invokeAction(AnalyticsAction action, [List<String> vendorIds = ALL]) async {
     final List<AnalyticsVendor> vendorsToUse = _filterVendors(vendorIds);
 
-    for (final vendor in vendorsToUse) {
-      await vendor.handleAction(action);
-    }
+    await Future.wait(vendorsToUse.map((vendor) => vendor.handleAction(action))); //Do all the actions in parallel
   }
 
   List<AnalyticsVendor> _filterVendors(List<String> vendorIds) {