Update test scheduler

Author: rossanafmenezes

WooCommerce/src/main/kotlin/com/woocommerce/android/media/MediaFilesRepository.kt

@@ -10,6 +10,7 @@ import com.woocommerce.android.util.CoroutineDispatchers
 import com.woocommerce.android.util.WooLog
 import com.woocommerce.android.util.WooLog.T
 import com.woocommerce.android.viewmodel.ResourceProvider
+import kotlinx.coroutines.DelicateCoroutinesApi
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.channels.ProducerScope
 import kotlinx.coroutines.channels.awaitClose
@@ -59,7 +60,7 @@ class MediaFilesRepository @Inject constructor(
         }
     }
 
-    @OptIn(ExperimentalCoroutinesApi::class)
+    @OptIn(DelicateCoroutinesApi::class)
     fun uploadMedia(localMediaModel: MediaModel, stripLocation: Boolean = true): Flow<UploadResult> {
         return callbackFlow {
             WooLog.d(T.MEDIA, "MediaFilesRepository > Dispatching request to upload ${localMediaModel.filePath}")

WooCommerce/src/test/kotlin/com/woocommerce/android/ui/reviews/ReviewModerationHandlerTests.kt

@@ -86,7 +86,7 @@ class ReviewModerationHandlerTests {
 
             val latestStatus = runTestAndCollectLastStatus {
                 handler.postModerationRequest(review, HOLD)
-                advanceTimeBy(ReviewModerationHandler.UNDO_DELAY)
+                testScheduler.apply { advanceTimeBy(ReviewModerationHandler.UNDO_DELAY); runCurrent() }
             }
 
             assertThat(latestStatus.actionStatus).isEqualTo(ActionStatus.SUBMITTED)
@@ -108,7 +108,7 @@ class ReviewModerationHandlerTests {
 
             val latestStatus = runTestAndCollectLastStatus {
                 handler.postModerationRequest(review, HOLD)
-                advanceTimeBy(ReviewModerationHandler.UNDO_DELAY)
+                testScheduler.apply { advanceTimeBy(ReviewModerationHandler.UNDO_DELAY); runCurrent() }
             }
 
             assertThat(latestStatus.actionStatus).isEqualTo(ActionStatus.SUCCESS)
@@ -130,8 +130,8 @@ class ReviewModerationHandlerTests {
 
             val statusList = runTestAndReturnLastEmittedStatusList {
                 handler.postModerationRequest(review, HOLD)
-                advanceTimeBy(ReviewModerationHandler.UNDO_DELAY)
-                advanceTimeBy(ReviewModerationHandler.SUCCESS_DELAY)
+                testScheduler.apply { advanceTimeBy(ReviewModerationHandler.UNDO_DELAY); runCurrent() }
+                testScheduler.apply { advanceTimeBy(ReviewModerationHandler.SUCCESS_DELAY); runCurrent() }
             }
 
             assertThat(statusList).isEmpty()
@@ -149,7 +149,7 @@ class ReviewModerationHandlerTests {
 
         val latestStatus = runTestAndCollectLastStatus {
             handler.postModerationRequest(review, HOLD)
-            advanceTimeBy(ReviewModerationHandler.UNDO_DELAY)
+            testScheduler.apply { advanceTimeBy(ReviewModerationHandler.UNDO_DELAY); runCurrent() }
         }
 
         assertThat(latestStatus.actionStatus).isEqualTo(ActionStatus.ERROR)
@@ -167,8 +167,8 @@ class ReviewModerationHandlerTests {
 
         val statusList = runTestAndReturnLastEmittedStatusList {
             handler.postModerationRequest(review, HOLD)
-            advanceTimeBy(ReviewModerationHandler.UNDO_DELAY)
-            advanceTimeBy(ReviewModerationHandler.ERROR_SNACKBAR_DELAY)
+            testScheduler.apply { advanceTimeBy(ReviewModerationHandler.UNDO_DELAY); runCurrent() }
+            testScheduler.apply { advanceTimeBy(ReviewModerationHandler.ERROR_SNACKBAR_DELAY); runCurrent() }
         }
 
         assertThat(statusList).isEmpty()
@@ -180,7 +180,7 @@ class ReviewModerationHandlerTests {
 
         val latestStatus = runTestAndCollectLastStatus {
             handler.postModerationRequest(review, HOLD)
-            advanceTimeBy(ReviewModerationHandler.UNDO_DELAY / 2)
+            testScheduler.apply { advanceTimeBy(ReviewModerationHandler.UNDO_DELAY / 2); runCurrent() }
             handler.undoOperation(review)
         }