fix test

Author: themiswang

firebase-crashlytics/src/androidTest/java/com/google/firebase/crashlytics/internal/common/CrashlyticsControllerTest.java

@@ -72,6 +72,8 @@ public class CrashlyticsControllerTest extends CrashlyticsTestCase {
   private DataCollectionArbiter mockDataCollectionArbiter;
   private CrashlyticsNativeComponent mockNativeComponent = mock(CrashlyticsNativeComponent.class);
 
+  private CrashlyticsWorker diskWriteWorker = new CrashlyticsWorker(TestOnlyExecutors.background());
+
   @Override
   protected void setUp() throws Exception {
     super.setUp();
@@ -182,7 +184,7 @@ public CrashlyticsController build() {
               nativeComponent,
               analyticsEventLogger,
               mock(CrashlyticsAppQualitySessionsSubscriber.class),
-              new CrashlyticsWorker(TestOnlyExecutors.background()));
+              diskWriteWorker);
       return controller;
     }
   }
@@ -366,13 +368,14 @@ public void testLoggedExceptionsAfterCrashOk() {
    */
   // FIXME: Validate this test works as intended
   @SdkSuppress(minSdkVersion = 30) // ApplicationExitInfo
-  public void testLogStringAfterCrashOk() {
+  public void testLogStringAfterCrashOk() throws Exception {
     final CrashlyticsController controller = builder().build();
     controller.handleUncaughtException(
         testSettingsProvider, Thread.currentThread(), new RuntimeException());
 
     // This should not throw.
-    controller.writeToLog(System.currentTimeMillis(), "Hi");
+    diskWriteWorker.submit(() -> controller.writeToLog(System.currentTimeMillis(), "Hi"));
+    diskWriteWorker.await();
   }
 
   /**