Peertube
/
NewPipe-app-android
mirror of https://github.com/TeamNewPipe/NewPipe/
1
0
Fork 0
Code Issues Releases Wiki Activity

Update stream state in database after loading

This commit is contained in:
Douile 2021-10-28 01:11:53 +01:00
parent 62d36126ea
commit bc2f0f9f3e
No known key found for this signature in database
GPG Key ID: DAB413485BA6CFFD
2 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
app/src/main/java/org/schabi/newpipe/local/feed/FeedFragment.kt
View File

@ -159,6 +159,11 @@ class FeedFragment : BaseStateFragment<FeedState>() {
}
}
// TODO: Move
fun redrawContent() {
groupAdapter.notifyItemRangeChanged(0, Int.MAX_VALUE)
}
fun setupListViewMode() {
// does everything needed to setup the layouts for grid or list modes
groupAdapter.spanCount = if (shouldUseGridLayout(context)) getGridSpanCountStreams(context) else 1

19
app/src/main/java/org/schabi/newpipe/util/StreamDialogEntry.java
View File

@ -62,13 +62,13 @@ public enum StreamDialogEntry {
* Info: Add this entry within showStreamDialog.
*/
enqueue(R.string.enqueue_stream, (fragment, item) -> {
fetchItemInfoIfSparse(item,
fetchItemInfoIfSparse(fragment, item,
fullItem -> NavigationHelper.enqueueOnPlayer(fragment.getContext(), fullItem)
);
}),
enqueue_next(R.string.enqueue_next_stream, (fragment, item) -> {
fetchItemInfoIfSparse(item,
fetchItemInfoIfSparse(fragment, item,
fullItem -> NavigationHelper.enqueueNextOnPlayer(fragment.getContext(), fullItem)
);
}),
@ -218,8 +218,9 @@ public enum StreamDialogEntry {
void onInfo(SinglePlayQueue item);
}
private static void fetchItemInfoIfSparse(final StreamInfoItem item,
final InfoCallback callback) {
private static void fetchItemInfoIfSparse(final Fragment fragment,
final StreamInfoItem item,
final InfoCallback callback) {
if (item.getDuration() < 0) {
// Sparse item: fetched by fast fetch
final Disposable currentWorker = ExtractorHelper.getStreamInfo(
@ -227,9 +228,19 @@ public enum StreamDialogEntry {
item.getUrl(),
false
)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(result -> {
final HistoryRecordManager recordManager =
new HistoryRecordManager(fragment.getContext());
recordManager.saveStreamState(result, 0)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doOnError(throwable -> Log.e("StreamDialogEntry",
throwable.toString()))
.subscribe();
callback.onInfo(new SinglePlayQueue(result));
}, throwable -> Log.e("StreamDialogEntry", throwable.toString()));
} else {