File tree Expand file tree Collapse file tree 1 file changed +14
-13
lines changed
common/main/java/com/couchbase/lite Expand file tree Collapse file tree 1 file changed +14
-13
lines changed Original file line number Diff line number Diff line change 3232import java .util .List ;
3333import java .util .Set ;
3434import java .util .concurrent .Executor ;
35- import java .util .concurrent .atomic .AtomicBoolean ;
3635import java .util .concurrent .atomic .AtomicReference ;
3736
3837import com .couchbase .lite .internal .CouchbaseLiteInternal ;
@@ -178,18 +177,20 @@ public void start(boolean resetCheckpoint) {
178177
179178 getDatabase ().addActiveReplicator (this );
180179
181- getDatabase ().registerProcess (new AbstractDatabase .ActiveProcess <ConflictResolverService >(conflictResolverService ) {
182- @ Override
183- public void stop () {
184- conflictResolverService .shutdown (false , () -> {});
185- }
186-
187- @ Override
188- public boolean isActive () {
189- // Service is active if it's not in STOPPED state
190- return conflictResolverService .isActive ();
191- }
192- });
180+ getDatabase ().registerProcess (
181+ new AbstractDatabase .ActiveProcess <ConflictResolverService >(conflictResolverService ) {
182+ @ Override
183+ public void stop () {
184+ conflictResolverService .shutdown (false , () -> {
185+ });
186+ }
187+
188+ @ Override
189+ public boolean isActive () {
190+ // Service is active if it's not in STOPPED state
191+ return conflictResolverService .isActive ();
192+ }
193+ });
193194
194195 final C4Replicator c4Repl ;
195196 try { c4Repl = getOrCreateC4Replicator (); }
You can’t perform that action at this time.
0 commit comments