From fb0c5fdaaa02cbf9efbe664ae49134f3dffbcbac Mon Sep 17 00:00:00 2001
From: Bradlee Speice <bspeice.nc@gmail.com>
Date: Tue, 10 Jun 2014 22:56:52 -0400
Subject: [PATCH] [broken] BookListFragment to Rx

---
 .../downloader/BookListFragment.java          | 27 +++++++++----------
 .../downloader/manager/RefreshManager.java    |  4 +++
 2 files changed, 16 insertions(+), 15 deletions(-)

diff --git a/MinimalBible/src/main/java/org/bspeice/minimalbible/activities/downloader/BookListFragment.java b/MinimalBible/src/main/java/org/bspeice/minimalbible/activities/downloader/BookListFragment.java
index 67b399c..8858a74 100644
--- a/MinimalBible/src/main/java/org/bspeice/minimalbible/activities/downloader/BookListFragment.java
+++ b/MinimalBible/src/main/java/org/bspeice/minimalbible/activities/downloader/BookListFragment.java
@@ -24,6 +24,7 @@ import org.crosswire.jsword.book.BookComparators;
 import org.crosswire.jsword.book.BookFilter;
 import org.crosswire.jsword.book.FilterUtil;
 
+import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 
@@ -31,6 +32,7 @@ import javax.inject.Inject;
 
 import butterknife.ButterKnife;
 import butterknife.InjectView;
+import rx.android.schedulers.AndroidSchedulers;
 
 /**
  * A placeholder fragment containing a simple view.
@@ -118,28 +120,23 @@ public class BookListFragment extends BaseFragment {
      */
 	private void refreshModules() {
         // Check if the downloadManager has already refreshed everything
-		List<Book> bookList = refreshManager.getBookList();
-		if (bookList == null) {
+		if (!refreshManager.isRefreshComplete()) {
             // downloadManager is in progress of refreshing
-            downloadManager.getDownloadBus().register(this);
             refreshDialog = new ProgressDialog(getActivity());
             refreshDialog.setMessage("Refreshing available modules...");
             refreshDialog.setCancelable(false);
             refreshDialog.show();
-        } else {
-            displayBooks(bookList);
         }
-	}
 
-    /**
-     * Used by GreenRobot for notifying us that the book refresh is complete
-     */
-    @SuppressWarnings("unused")
-	public void onEventMainThread(EventBookList event) {
-		if (refreshDialog != null) {
-			refreshDialog.cancel();
-		}
-		displayBooks(event.getBookList());
+        // Listen for the books!
+        refreshManager.getAvailableModules().subscribeOn(AndroidSchedulers.mainThread())
+                .reduce(new ArrayList<Book>(), (books, installerListMap) -> {
+                    for (List<Book> l : installerListMap.values()) {
+                        books.addAll(l);
+                    }
+                    return books;
+                }).take(1)
+                .subscribe((books) -> displayBooks(books));
 	}
 
     /**
diff --git a/MinimalBible/src/main/java/org/bspeice/minimalbible/activities/downloader/manager/RefreshManager.java b/MinimalBible/src/main/java/org/bspeice/minimalbible/activities/downloader/manager/RefreshManager.java
index 4e036b9..4d572cb 100644
--- a/MinimalBible/src/main/java/org/bspeice/minimalbible/activities/downloader/manager/RefreshManager.java
+++ b/MinimalBible/src/main/java/org/bspeice/minimalbible/activities/downloader/manager/RefreshManager.java
@@ -58,6 +58,10 @@ public class RefreshManager {
         }
     }
 
+    public Observable<Map<Installer, List<Book>>> getAvailableModules() {
+        return getAvailableModules();
+    }
+
     /**
      * Get the cached book list
      * @return The cached book list, or null