fix bug

Author: codeestX

app/src/main/java/com/codeest/geeknews/base/RxPresenter.java

@@ -17,7 +17,7 @@ public class RxPresenter<T extends BaseView> implements BasePresenter<T> {
 
     protected void unSubscribe() {
         if (mCompositeDisposable != null) {
-            mCompositeDisposable.dispose();
+            mCompositeDisposable.clear();
         }
     }
 

app/src/main/java/com/codeest/geeknews/presenter/zhihu/DailyPresenter.java

@@ -169,7 +169,11 @@ public void onNext(DailyBeforeListBean dailyBeforeListBean) {
 
     @Override
     public void startInterval() {
+        if (intervalSubscription != null && !intervalSubscription.isDisposed()) {
+            return;
+        }
         intervalSubscription = Flowable.interval(INTERVAL_INSTANCE, TimeUnit.SECONDS)
+                .onBackpressureDrop()
                 .compose(RxUtil.<Long>rxSchedulerHelper())
                 .subscribe(new Consumer<Long>() {
                     @Override
@@ -184,7 +188,7 @@ public void accept(Long aLong) {
 
     @Override
     public void stopInterval() {
-        if (intervalSubscription != null) {
+        if (intervalSubscription != null && !intervalSubscription.isDisposed()) {
             intervalSubscription.dispose();
         }
     }

app/src/main/java/com/codeest/geeknews/ui/zhihu/fragment/DailyFragment.java

@@ -45,6 +45,8 @@ public class DailyFragment extends RootFragment<DailyPresenter> implements Daily
     DailyAdapter mAdapter;
     List<DailyListBean.StoriesBean> mList = new ArrayList<>();
 
+    boolean isDataReady = false;
+
     @Override
     protected void initInject() {
         getFragmentComponent().inject(this);
@@ -97,6 +99,20 @@ public void onRefresh() {
         mPresenter.getDailyData();
     }
 
+    @Override
+    public void onStart() {
+        super.onStart();
+        if (isDataReady) {
+            mPresenter.startInterval();
+        }
+    }
+
+    @Override
+    public void onStop() {
+        super.onStop();
+        mPresenter.stopInterval();
+    }
+
     /**
      * 当天数据
      * @param info
@@ -110,7 +126,7 @@ public void showContent(DailyListBean info) {
         mList = info.getStories();
         currentDate = String.valueOf(Integer.valueOf(info.getDate()) + 1);
         mAdapter.addDailyDate(info);
-        mPresenter.stopInterval();
+        isDataReady = true;
         mPresenter.startInterval();
     }
 
@@ -125,6 +141,7 @@ public void showMoreContent(String date,DailyBeforeListBean info) {
             swipeRefresh.setRefreshing(false);
         }
         stateMain();
+        isDataReady = false;
         mPresenter.stopInterval();
         mList = info.getStories();
         currentDate = String.valueOf(Integer.valueOf(info.getDate()));