Update component runtime to pick up any one of the couroutine dispatcher interface (firebase#5300)

Author: VinayGuthal

firebase-components/CHANGELOG.md

@@ -1,3 +1,7 @@
 # Unreleased
+* [changed] Internal changes to ensure only one interface is provided for 
+ kotlinx.coroutines.CoroutineDispatcher interfaces when both firebase-common and
+ firebase-common-ktx provide them.
+
 
 

firebase-components/src/main/java/com/google/firebase/components/ComponentRuntime.java

@@ -49,6 +49,7 @@ public class ComponentRuntime implements ComponentContainer, ComponentLoader {
  private final Map<Qualified<?>, Provider<?>> lazyInstanceMap = new HashMap<>();
  private final Map<Qualified<?>, LazySet<?>> lazySetMap = new HashMap<>();
  private final List<Provider<ComponentRegistrar>> unprocessedRegistrarProviders;
+ private Set<String> processedCoroutineDispatcherInterfaces = new HashSet<>();
  private final EventBus eventBus;
  private final AtomicReference<Boolean> eagerComponentsInitializedWith = new AtomicReference<>();
  private final ComponentRegistrarProcessor componentRegistrarProcessor;
@@ -123,6 +124,25 @@ private void discoverComponents(List<Component<?>> componentsToAdd) {
  }
  }
 
+ // kotlinx.coroutines.CoroutineDispatcher interfaces could be provided by both new version of
+ // firebase-common and old version of firebase-common-ktx. In this scenario take the first
+ // interface which was provided.
+
+ Iterator<Component<?>> it = componentsToAdd.iterator();
+ while (it.hasNext()) {
+ Component component = it.next();
+ for (Object anInterface : component.getProvidedInterfaces().toArray()) {
+ if (anInterface.toString().contains("kotlinx.coroutines.CoroutineDispatcher")) {
+ if (processedCoroutineDispatcherInterfaces.contains(anInterface.toString())) {
+ it.remove();
+ break;
+ } else {
+ processedCoroutineDispatcherInterfaces.add(anInterface.toString());
+ }
+ }
+ }
+ }
+
  if (components.isEmpty()) {
  CycleDetector.detect(componentsToAdd);
  } else {