From 44ea254f52629637de00eefc40df33d505aa40bc Mon Sep 17 00:00:00 2001 From: Jobobby04 Date: Sat, 4 Jun 2022 20:36:43 -0400 Subject: [PATCH] Use launchUI in MangaPresenter --- .../tachiyomi/ui/manga/MangaPresenter.kt | 23 ++++++------------- 1 file changed, 7 insertions(+), 16 deletions(-) diff --git a/app/src/main/java/eu/kanade/tachiyomi/ui/manga/MangaPresenter.kt b/app/src/main/java/eu/kanade/tachiyomi/ui/manga/MangaPresenter.kt index beb054980..de6198a1e 100644 --- a/app/src/main/java/eu/kanade/tachiyomi/ui/manga/MangaPresenter.kt +++ b/app/src/main/java/eu/kanade/tachiyomi/ui/manga/MangaPresenter.kt @@ -38,6 +38,7 @@ import eu.kanade.tachiyomi.util.chapter.syncChaptersWithSource import eu.kanade.tachiyomi.util.chapter.syncChaptersWithTrackServiceTwoWay import eu.kanade.tachiyomi.util.isLocal import eu.kanade.tachiyomi.util.lang.launchIO +import eu.kanade.tachiyomi.util.lang.launchUI import eu.kanade.tachiyomi.util.lang.withUIContext import eu.kanade.tachiyomi.util.prepUpdateCover import eu.kanade.tachiyomi.util.removeCovers @@ -380,24 +381,14 @@ class MangaPresenter( } if (uri == null && resetCover) { - Observable.just(manga) - .subscribeOn(Schedulers.io()) - .observeOn(AndroidSchedulers.mainThread()) - .subscribeLatestCache( - { view, _ -> - view.setRefreshing() - }, - ) + launchUI { + view?.setRefreshing() + } fetchMangaFromSource(manualFetch = true) } else { - Observable.just(manga) - .subscribeOn(Schedulers.io()) - .observeOn(AndroidSchedulers.mainThread()) - .subscribeLatestCache( - { view, _ -> - view.onNextMangaInfo(manga, source, meta.value) - }, - ) + launchUI { + view?.onNextMangaInfo(manga, source, meta.value) + } } }