mirror/SmartTube
1
0
Fork 0
mirror of https://github.com/yuliskov/SmartTube.git synced 2026-01-14 02:10:12 -06:00
Code Issues Packages Projects Releases Wiki Activity

add channel scroll

Browse Source
This commit is contained in:
Yuriy Liskov
2020-09-30 19:23:52 +03:00
parent 7c8a0ece50
commit 3bc96ffe12
2 changed files with 37 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
SharedModules

Submodule SharedModules updated: 6e8d887c56...4ee1960a74

42
common/src/main/java/com/liskovsoft/smartyoutubetv2/common/app/presenters/ChannelPresenter.java
View File

@@ -2,6 +2,7 @@ package com.liskovsoft.smartyoutubetv2.common.app.presenters;
import android.annotation.SuppressLint;
import android.content.Context;
import com.liskovsoft.mediaserviceinterfaces.MediaGroupManager;
import com.liskovsoft.mediaserviceinterfaces.MediaService;
import com.liskovsoft.mediaserviceinterfaces.data.MediaGroup;
import com.liskovsoft.sharedutils.helpers.MessageHelpers;
@@ -28,8 +29,9 @@ public class ChannelPresenter implements VideoGroupPresenter<ChannelView> {
private final MediaService mMediaService;
private final PlaybackPresenter mPlaybackPresenter;
private ChannelView mView;
private Disposable mUpdateAction;
private String mChannelId;
private Disposable mUpdateAction;
private Disposable mScrollAction;
public ChannelPresenter(Context context) {
mContext = context;
@@ -65,7 +67,13 @@ public class ChannelPresenter implements VideoGroupPresenter<ChannelView> {
@Override
public void onScrollEnd(VideoGroup group) {
Log.d(TAG, "onScrollEnd: Group title: " + group.getTitle());
boolean scrollInProgress = mScrollAction != null && !mScrollAction.isDisposed();
if (!scrollInProgress) {
continueGroup(group);
}
}
@Override
@@ -76,6 +84,8 @@ public class ChannelPresenter implements VideoGroupPresenter<ChannelView> {
@Override
public void unregister(ChannelView view) {
mView = null;
disposeActions();
}
public void openChannel(String channelId) {
@@ -83,7 +93,7 @@ public class ChannelPresenter implements VideoGroupPresenter<ChannelView> {
return;
}
disposeUpdateAction();
disposeActions();
ViewManager.instance(mContext).startView(ChannelView.class);
if (mView != null) {
@@ -94,12 +104,14 @@ public class ChannelPresenter implements VideoGroupPresenter<ChannelView> {
}
}
private void disposeUpdateAction() {
boolean updateInProgress = mUpdateAction != null && !mUpdateAction.isDisposed();
if (updateInProgress) {
private void disposeActions() {
if (mUpdateAction != null && !mUpdateAction.isDisposed()) {
mUpdateAction.dispose();
}
if (mScrollAction != null && !mScrollAction.isDisposed()) {
mScrollAction.dispose();
}
}
private void updateRows(String channelId) {
@@ -131,4 +143,22 @@ public class ChannelPresenter implements VideoGroupPresenter<ChannelView> {
mView.update(VideoGroup.from(mediaGroup));
}
}
private void continueGroup(VideoGroup group) {
Log.d(TAG, "continueGroup: start continue group: " + group.getTitle());
mView.showProgressBar(true);
MediaGroup mediaGroup = group.getMediaGroup();
MediaGroupManager mediaGroupManager = mMediaService.getMediaGroupManager();
mScrollAction = mediaGroupManager.continueGroupObserve(mediaGroup)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(continueMediaGroup -> {
mView.update(VideoGroup.from(continueMediaGroup));
}, error -> Log.e(TAG, "continueGroup error: " + error),
() -> mView.showProgressBar(false));
}
}