Use launchUI in MangaPresenter

This commit is contained in:
Jobobby04 2022-06-04 20:36:43 -04:00
parent 706315625e
commit 44ea254f52

View File

@ -38,6 +38,7 @@ import eu.kanade.tachiyomi.util.chapter.syncChaptersWithSource
import eu.kanade.tachiyomi.util.chapter.syncChaptersWithTrackServiceTwoWay import eu.kanade.tachiyomi.util.chapter.syncChaptersWithTrackServiceTwoWay
import eu.kanade.tachiyomi.util.isLocal import eu.kanade.tachiyomi.util.isLocal
import eu.kanade.tachiyomi.util.lang.launchIO 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.lang.withUIContext
import eu.kanade.tachiyomi.util.prepUpdateCover import eu.kanade.tachiyomi.util.prepUpdateCover
import eu.kanade.tachiyomi.util.removeCovers import eu.kanade.tachiyomi.util.removeCovers
@ -380,24 +381,14 @@ class MangaPresenter(
} }
if (uri == null && resetCover) { if (uri == null && resetCover) {
Observable.just(manga) launchUI {
.subscribeOn(Schedulers.io()) view?.setRefreshing()
.observeOn(AndroidSchedulers.mainThread()) }
.subscribeLatestCache(
{ view, _ ->
view.setRefreshing()
},
)
fetchMangaFromSource(manualFetch = true) fetchMangaFromSource(manualFetch = true)
} else { } else {
Observable.just(manga) launchUI {
.subscribeOn(Schedulers.io()) view?.onNextMangaInfo(manga, source, meta.value)
.observeOn(AndroidSchedulers.mainThread()) }
.subscribeLatestCache(
{ view, _ ->
view.onNextMangaInfo(manga, source, meta.value)
},
)
} }
} }