Add composite subscriptions

app/src/main/java/eu/kanade/mangafeed/presenter/LibraryPresenter.java

@@ -11,7 +11,6 @@ import eu.kanade.mangafeed.data.models.Manga;
 import eu.kanade.mangafeed.ui.activity.MangaDetailActivity;
 import eu.kanade.mangafeed.ui.adapter.LibraryAdapter;
 import eu.kanade.mangafeed.view.LibraryView;
-import rx.Subscription;
 
 import static rx.android.schedulers.AndroidSchedulers.mainThread;
 
@@ -23,7 +22,6 @@ public class LibraryPresenter extends BasePresenter {
     @Inject PreferencesHelper prefs;
 
     LibraryAdapter<Manga> adapter;
-    private Subscription mangaListSubscription;
 
     public LibraryPresenter(LibraryView view) {
         this.view = view;
@@ -47,22 +45,18 @@ public class LibraryPresenter extends BasePresenter {
     }
 
     public void initializeMangas() {
-        mangaListSubscription = db.manga.getWithUnread()
-                .observeOn(mainThread())
-                .subscribe(mangas -> {
-                    adapter = new LibraryAdapter<>(view.getActivity(), mangas);
-                    view.setAdapter(adapter);
-                });
+        adapter = new LibraryAdapter<>(view.getActivity());
+        view.setAdapter(adapter);
+        view.setMangaClickListener();
+
+        subscriptions.add(db.manga.getWithUnread()
+                        .observeOn(mainThread())
+                        .subscribe(adapter::setNewItems)
+        );
     }
 
     public void onQueryTextChange(String query) {
         adapter.getFilter().filter(query);
     }
 
-    public void destroySubscriptions() {
-        if (mangaListSubscription != null) {
-            mangaListSubscription.unsubscribe();
-        }
-    }
-
 }