Revert "fix(datastore): Fix MutationProcessorRetryTest" (#2419)

aws-amplify · Apr 27, 2023 · 28737c0 · 28737c0
1 parent fd6bcd8
commit 28737c0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/aws-datastore/src/main/java/com/amplifyframework/datastore/syncengine/ReachabilityMonitor.kt b/aws-datastore/src/main/java/com/amplifyframework/datastore/syncengine/ReachabilityMonitor.kt
@@ -29,7 +29,7 @@ import java.util.concurrent.TimeUnit
 /**
  * The ReachabilityMonitor is responsible for watching the network status as provided by the OS.
  * It returns an observable that publishes "true" when the network becomes available and "false" when
- * the network is lost.
+ * the network is lost.  It publishes the current status on subscription.
  *
  * ReachabilityMonitor does not try to monitor the DataStore websockets or the status of the AppSync service.
  *
@@ -64,6 +64,8 @@ private class ReachabilityMonitorImpl constructor(val schedulerProvider: Schedul
         emitter = ObservableOnSubscribe { emitter ->
             val callback = getCallback(emitter)
             connectivityProvider.registerDefaultNetworkCallback(context, callback)
+            // Provide the current network status upon subscription.
+            emitter.onNext(connectivityProvider.hasActiveNetwork)
         }
     }
 

diff --git a/...astore/src/test/java/com/amplifyframework/datastore/syncengine/ReachabilityMonitorTest.kt b/...astore/src/test/java/com/amplifyframework/datastore/syncengine/ReachabilityMonitorTest.kt
@@ -67,6 +67,6 @@ class ReachabilityMonitorTest {
         // Should provide true after debounce
         testScheduler.advanceTimeBy(251, TimeUnit.MILLISECONDS)
 
-        testSubscriber.assertValues(false, true, true)
+        testSubscriber.assertValues(true, false, true, true)
     }
 }