File tree Expand file tree Collapse file tree 1 file changed +2
-6
lines changed
java-server/src/main/java/com/ditto/example/spring/quickstart/service Expand file tree Collapse file tree 1 file changed +2
-6
lines changed Original file line number Diff line number Diff line change @@ -100,11 +100,7 @@ public Flux<Boolean> getSyncState() {
100100
101101 public void toggleSync () {
102102 boolean currentSyncState = Boolean .TRUE .equals (mutableSyncStatePublisher .asFlux ().blockFirst ());
103- try {
104- setSyncStateIntoDittoStore (!currentSyncState );
105- } catch (DittoException e ) {
106- throw new RuntimeException (e );
107- }
103+ setSyncStateIntoDittoStore (!currentSyncState );
108104 }
109105
110106 private DittoAsyncCancellable observePeersPresence () {
@@ -172,7 +168,7 @@ private DittoStoreObserver setupAndObserveSyncState() {
172168 }
173169 }
174170
175- private void setSyncStateIntoDittoStore (boolean newState ) throws DittoException {
171+ private void setSyncStateIntoDittoStore (boolean newState ) {
176172 CompletionStage <DittoQueryResult > future = ditto .getStore ().execute (
177173 "UPDATE %s SET %s = :syncState" .formatted (DITTO_SYNC_STATE_COLLECTION , DITTO_SYNC_STATE_ID ),
178174 DittoCborSerializable .buildDictionary ()
You can’t perform that action at this time.
0 commit comments