Use Firebase executors for realtime.

Author: danasilver

firebase-config/ktx/src/test/kotlin/com/google/firebase/remoteconfig/TestConstructorUtil.kt

@@ -38,7 +38,8 @@ fun createRemoteConfig(
   defaultConfigsCache: ConfigCacheClient,
   fetchHandler: ConfigFetchHandler,
   getHandler: ConfigGetParameterHandler,
-  frcMetadata: ConfigMetadataClient
+  frcMetadata: ConfigMetadataClient,
+  realtimeHandler: ConfigRealtimeHandler
 ): FirebaseRemoteConfig {
   return FirebaseRemoteConfig(
     context,
@@ -51,6 +52,7 @@ fun createRemoteConfig(
     defaultConfigsCache,
     fetchHandler,
     getHandler,
-    frcMetadata
+    frcMetadata,
+    realtimeHandler
   )
 }

firebase-config/ktx/src/test/kotlin/com/google/firebase/remoteconfig/ktx/RemoteConfigTests.kt

@@ -139,7 +139,8 @@ class ConfigTests : BaseTestCase() {
         defaultConfigsCache = mock(ConfigCacheClient::class.java),
         fetchHandler = mock(ConfigFetchHandler::class.java),
         getHandler = mockGetHandler,
-        frcMetadata = mock(ConfigMetadataClient::class.java)
+        frcMetadata = mock(ConfigMetadataClient::class.java),
+        realtimeHandler = mock(ConfigRealtimeHandler::class.java)
       )
 
     `when`(mockGetHandler.getValue("KEY")).thenReturn(StringRemoteConfigValue("non default value"))

firebase-config/src/main/java/com/google/firebase/remoteconfig/RemoteConfigComponent.java

@@ -43,6 +43,8 @@
 import java.util.Map;
 import java.util.Random;
 import java.util.concurrent.Executor;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.atomic.AtomicReference;
 
 /**
  * Component for providing multiple Firebase Remote Config (FRC) instances. Firebase Android
@@ -82,7 +84,7 @@ public class RemoteConfigComponent {
       new HashMap<>();
 
   private final Context context;
-  private final Executor executor;
+  private final ScheduledExecutorService executor;
   private final FirebaseApp firebaseApp;
   private final FirebaseInstallationsApi firebaseInstallations;
   private final FirebaseABTesting firebaseAbt;
@@ -96,7 +98,7 @@ public class RemoteConfigComponent {
   /** Firebase Remote Config Component constructor. */
   RemoteConfigComponent(
       Context context,
-      @Blocking Executor executor,
+      @Blocking ScheduledExecutorService executor,
       FirebaseApp firebaseApp,
       FirebaseInstallationsApi firebaseInstallations,
       FirebaseABTesting firebaseAbt,
@@ -115,7 +117,7 @@ public class RemoteConfigComponent {
   @VisibleForTesting
   protected RemoteConfigComponent(
       Context context,
-      Executor executor,
+      ScheduledExecutorService executor,
       FirebaseApp firebaseApp,
       FirebaseInstallationsApi firebaseInstallations,
       FirebaseABTesting firebaseAbt,
@@ -279,7 +281,7 @@ synchronized ConfigRealtimeHandler getRealtime(
         activatedCacheClient,
         context,
         namespace,
-        scheduledExecutorService);
+        executor);
   }
 
   private ConfigGetParameterHandler getGetHandler(

firebase-config/src/main/java/com/google/firebase/remoteconfig/RemoteConfigRegistrar.java

@@ -30,6 +30,7 @@
 import java.util.Arrays;
 import java.util.List;
 import java.util.concurrent.Executor;
+import java.util.concurrent.ScheduledExecutorService;
 
 /**
  * Registrar for setting up Firebase Remote Config's dependency injections in Firebase Android
@@ -44,7 +45,7 @@ public class RemoteConfigRegistrar implements ComponentRegistrar {
 
   @Override
   public List<Component<?>> getComponents() {
-    Qualified<Executor> blockingExecutor = Qualified.qualified(Blocking.class, Executor.class);
+    Qualified<ScheduledExecutorService> blockingExecutor = Qualified.qualified(Blocking.class, ScheduledExecutorService.class);
     return Arrays.asList(
         Component.builder(RemoteConfigComponent.class)
             .name(LIBRARY_NAME)

firebase-config/src/test/java/com/google/firebase/remoteconfig/RemoteConfigComponentTest.java

@@ -175,7 +175,6 @@ public void getFetchHandler_nonMainFirebaseApp_doesNotUseAnalytics() {
   private RemoteConfigComponent getNewFrcComponent() {
     return new RemoteConfigComponent(
         context,
-        directExecutor,
         scheduledExecutorService,
         mockFirebaseApp,
         mockFirebaseInstallations,
@@ -187,7 +186,6 @@ private RemoteConfigComponent getNewFrcComponent() {
   private RemoteConfigComponent getNewFrcComponentWithoutLoadingDefault() {
     return new RemoteConfigComponent(
         context,
-        directExecutor,
         scheduledExecutorService,
         mockFirebaseApp,
         mockFirebaseInstallations,