From 4382deb9430e81ae0a28811c96d4941a35186f7a Mon Sep 17 00:00:00 2001
From: Jobobby04 <jobobby04@users.noreply.github.com>
Date: Fri, 12 Jun 2020 19:31:33 -0400
Subject: [PATCH] Fix read history removal

---
 .../ui/recent/history/HistoryPresenter.kt          | 14 ++++++--------
 1 file changed, 6 insertions(+), 8 deletions(-)

diff --git a/app/src/main/java/eu/kanade/tachiyomi/ui/recent/history/HistoryPresenter.kt b/app/src/main/java/eu/kanade/tachiyomi/ui/recent/history/HistoryPresenter.kt
index f2a0bcd68..93807b896 100644
--- a/app/src/main/java/eu/kanade/tachiyomi/ui/recent/history/HistoryPresenter.kt
+++ b/app/src/main/java/eu/kanade/tachiyomi/ui/recent/history/HistoryPresenter.kt
@@ -103,8 +103,8 @@ class HistoryPresenter : BasePresenter<HistoryController>() {
      */
     fun removeFromHistory(history: History) {
         history.last_read = 0L
-        db.updateHistoryLastRead(history).asRxObservable()
-            .subscribe()
+        db.updateHistoryLastRead(history).executeAsBlocking()
+        updateList()
     }
 
     fun updateList(search: String? = null) {
@@ -123,12 +123,10 @@ class HistoryPresenter : BasePresenter<HistoryController>() {
      * @param mangaId id of manga
      */
     fun removeAllFromHistory(mangaId: Long) {
-        db.getHistoryByMangaId(mangaId).asRxSingle()
-            .map { list ->
-                list.forEach { it.last_read = 0L }
-                db.updateHistoryLastRead(list).executeAsBlocking()
-            }
-            .subscribe()
+        val history = db.getHistoryByMangaId(mangaId).executeAsBlocking()
+        history.forEach { it.last_read = 0L }
+        db.updateHistoryLastRead(history).executeAsBlocking()
+        updateList()
     }
 
     /**