Added stillLoading = false to onCompleted RxPager

Author: Victor

README.md

@@ -6,7 +6,7 @@ Add OkAdapter dependency to project level build.gradle.
 
 ```gradle
 dependencies {
-    compile 'com.github.FuckBoilerplate:OkAdapters:0.0.9'
+    compile 'com.github.FuckBoilerplate:OkAdapters:0.1.0'
 }
 ```
 

app/build.gradle

@@ -27,6 +27,8 @@ dependencies {
     compile "com.jakewharton:butterknife:7.0.1"
     compile 'io.reactivex:rxjava:1.1.5'
     compile 'io.reactivex:rxandroid:1.2.0'
+    compile 'com.trello:rxlifecycle:0.6.1'
+    compile 'com.trello:rxlifecycle-components:0.6.1'
 
     compile project(':ok_adapters')
 }

app/src/main/AndroidManifest.xml

@@ -30,6 +30,9 @@
 
         <activity android:name="app.stack_view.StackViewActivity"
             android:theme="@style/AppTheme.NoActionBar"/>
+
+        <activity android:name="app.recycler_view.DummyActivity"
+            android:theme="@style/AppTheme.NoActionBar"/>
     </application>
 
 </manifest>

app/src/main/java/app/recycler_view/DummyActivity.java

@@ -0,0 +1,9 @@
+package app.recycler_view;
+
+import android.app.Activity;
+
+/**
+ * Created by victor on 16/05/16.
+ */
+public class DummyActivity extends Activity {
+}

app/src/main/java/app/recycler_view/RecyclerViewPagerActivity.java

@@ -1,13 +1,16 @@
 package app.recycler_view;
 
+import android.content.Intent;
 import android.os.Bundle;
-import android.support.v7.app.AppCompatActivity;
 import android.support.v7.widget.GridLayoutManager;
 import android.support.v7.widget.RecyclerView;
 import android.view.View;
 import android.view.ViewGroup;
 import android.widget.Toast;
 
+import com.trello.rxlifecycle.RxLifecycle;
+import com.trello.rxlifecycle.components.support.RxAppCompatActivity;
+
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.TimeUnit;
@@ -22,7 +25,7 @@
 import rx.Observable;
 import rx.android.schedulers.AndroidSchedulers;
 
-public class RecyclerViewPagerActivity extends AppCompatActivity {
+public class RecyclerViewPagerActivity extends RxAppCompatActivity {
     @Bind(R.id.rv_items) RecyclerView rv_items;
     private boolean isReversed;
 
@@ -43,13 +46,15 @@ private void setUpRecyclerView(boolean reverseLayout) {
 
         adapter.setOnItemClickListener(new OkRecyclerViewAdapter.Listener<Item, ItemViewGroup>() {
             @Override public void onClickItem(Item item, ItemViewGroup itemViewGroup, int position) {
+                startActivity(new Intent(RecyclerViewPagerActivity.this, DummyActivity.class));
                 Toast.makeText(RecyclerViewPagerActivity.this, item.toString() + " " + "  Pos: " + position, Toast.LENGTH_SHORT).show();
             }
         });
 
         adapter.setRxPager(R.layout.loading_pager, new RxPager.LoaderPager<Item>() {
             @Override public Observable<List<Item>> onNextPage(Item lastItem) {
-                return getItems(lastItem);
+                return getItems(lastItem)
+                        .compose(RxLifecycle.<List<Item>>bindActivity(lifecycle()));
             }
         });
 
@@ -94,12 +99,12 @@ private Observable<List<Item>> getItems(Item lastItem) {
         if (index > 100) {
             List<Item> empty = new ArrayList();
             return Observable.just(empty)
-                    .delay(2, TimeUnit.SECONDS)
+                    .delay(3, TimeUnit.SECONDS)
                     .observeOn(AndroidSchedulers.mainThread());
         }
 
         return Observable.just(items)
-                .delay(2, TimeUnit.SECONDS)
+                .delay(3, TimeUnit.SECONDS)
                 .observeOn(AndroidSchedulers.mainThread());
     }
 

ok_adapters/src/main/java/library/recycler_view/RxPager.java

@@ -24,6 +24,7 @@
 import java.util.List;
 
 import rx.Observable;
+import rx.functions.Action0;
 import rx.functions.Action1;
 import rx.functions.Func1;
 
@@ -63,7 +64,11 @@ void reset(Observable<List<T>> oItems) {
 
     private void showItems(Observable<List<T>> oItems, final boolean reset) {
         stillLoading = true;
-        oItems.subscribe(new Action1<List<T>>() {
+        oItems.doOnCompleted(new Action0() {
+            @Override public void call() {
+                stillLoading = false;
+            }
+        }).subscribe(new Action1<List<T>>() {
             @Override public void call(final List<T> items) {
                 new Handler().post(new Runnable() {
                     @Override public void run() {