Create sub-package and default interval for DebounceSaver & sort playlists in db

2026-10-10 01:31:48 +00:00 · 2022-05-11 16:47:34 +08:00
parent 6526ff1612
commit d32490a4be
8 changed files with 35 additions and 17 deletions
@@ -0,0 +1,81 @@
+package org.schabi.newpipe.util.debounce;
+
+import org.schabi.newpipe.error.ErrorInfo;
+import org.schabi.newpipe.error.UserAction;
+
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
+import io.reactivex.rxjava3.disposables.Disposable;
+import io.reactivex.rxjava3.subjects.PublishSubject;
+
+public class DebounceSaver {
+
+    private final long saveDebounceMillis;
+
+    private final PublishSubject<Long> debouncedSaveSignal;
+
+    private final DebounceSavable debounceSavable;
+
+    // Has the object been modified
+    private final AtomicBoolean isModified;
+
+    // Default 10 seconds
+    private static final long DEFAULT_SAVE_DEBOUNCE_MILLIS = 10000;
+
+
+    /**
+     * Creates a new {@code DebounceSaver}.
+     *
+     * @param saveDebounceMillis    Save the object milliseconds later after the last change
+     *                              occurred.
+     * @param debounceSavable       The object containing data to be saved.
+     */
+    public DebounceSaver(final long saveDebounceMillis, final DebounceSavable debounceSavable) {
+        this.saveDebounceMillis = saveDebounceMillis;
+        debouncedSaveSignal = PublishSubject.create();
+        this.debounceSavable = debounceSavable;
+        this.isModified = new AtomicBoolean();
+    }
+
+    /**
+     * Creates a new {@code DebounceSaver}. Save the object 10 seconds later after the last change
+     * occurred.
+     *
+     * @param debounceSavable       The object containing data to be saved.
+     */
+    public DebounceSaver(final DebounceSavable debounceSavable) {
+        this(DEFAULT_SAVE_DEBOUNCE_MILLIS, debounceSavable);
+    }
+
+    public boolean getIsModified() {
+        return isModified.get();
+    }
+
+    public void setIsModified(final boolean isModified) {
+        this.isModified.set(isModified);
+    }
+
+    public PublishSubject<Long> getDebouncedSaveSignal() {
+        return debouncedSaveSignal;
+    }
+
+    public Disposable getDebouncedSaver() {
+        return debouncedSaveSignal
+                .debounce(saveDebounceMillis, TimeUnit.MILLISECONDS)
+                .observeOn(AndroidSchedulers.mainThread())
+                .subscribe(ignored -> debounceSavable.saveImmediate(), throwable ->
+                        debounceSavable.showError(new ErrorInfo(throwable,
+                                UserAction.SOMETHING_ELSE, "Debounced saver")));
+    }
+
+    public void saveChanges() {
+        if (isModified == null || debouncedSaveSignal == null) {
+            return;
+        }
+
+        isModified.set(true);
+        debouncedSaveSignal.onNext(System.currentTimeMillis());
+    }
+}