Don't need RxJava to call transitionToLocalOnly

aws-amplify · Jun 11, 2024 · 72f10e4 · 72f10e4
1 parent 6f945fc
commit 72f10e4
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/aws-datastore/src/main/java/com/amplifyframework/datastore/syncengine/Orchestrator.java b/aws-datastore/src/main/java/com/amplifyframework/datastore/syncengine/Orchestrator.java
@@ -404,12 +404,11 @@ private void onApiSyncFailure(Throwable exception) {
             return;
         }
         LOG.warn("API sync failed - transitioning to LOCAL_ONLY.", exception);
-        Disposable subscription = Completable.fromAction(this::transitionToLocalOnly)
-            .subscribe(
-                () -> { /* no-op */ },
-                error -> LOG.warn("Transition to LOCAL_ONLY failed.", error)
-            );
-        disposables.add(subscription);
+        try {
+            transitionToLocalOnly();
+        } catch (Exception error) {
+            LOG.warn("Transition to LOCAL_ONLY failed.", error);
+        }
     }
 
     private void disposeNetworkChanges() {