add clear orphans

This commit is contained in:
Christian Schabesberger 2018-04-29 17:06:54 +02:00
parent a079a0c901
commit 0471fd8145
1 changed files with 14 additions and 1 deletions

View File

@ -19,6 +19,7 @@ import org.schabi.newpipe.util.InfoCache;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
import io.reactivex.Single;
import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable; import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.disposables.Disposable; import io.reactivex.disposables.Disposable;
@ -74,6 +75,19 @@ public class HistorySettingsFragment extends BasePreferenceFragment {
"Delete view history", "Delete view history",
R.string.general_error))); R.string.general_error)));
final Disposable onClearOrphans = recordManager.removeOrphanedRecords()
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
howManyDeleted -> {},
throwable -> ErrorActivity.reportError(getContext(),
throwable,
SettingsActivity.class, null,
ErrorActivity.ErrorInfo.make(
UserAction.DELETE_FROM_HISTORY,
"none",
"Delete search history",
R.string.general_error)));
disposables.add(onClearOrphans);
disposables.add(onDelete); disposables.add(onDelete);
})) }))
.create() .create()
@ -99,7 +113,6 @@ public class HistorySettingsFragment extends BasePreferenceFragment {
"none", "none",
"Delete search history", "Delete search history",
R.string.general_error))); R.string.general_error)));
disposables.add(onDelete); disposables.add(onDelete);
})) }))
.create() .create()