mirror of
https://github.com/mihonapp/mihon.git
synced 2024-12-27 03:18:25 +01:00
Fix download status not updated properly after starting batch download (#7561)
This commit is contained in:
parent
b635f02d93
commit
473dc688f0
@ -417,7 +417,7 @@ class MangaPresenter(
|
|||||||
downloadManager.queue.getStatusAsFlow()
|
downloadManager.queue.getStatusAsFlow()
|
||||||
.filter { it.manga.id == successState?.manga?.id }
|
.filter { it.manga.id == successState?.manga?.id }
|
||||||
.catch { error -> logcat(LogPriority.ERROR, error) }
|
.catch { error -> logcat(LogPriority.ERROR, error) }
|
||||||
.collectLatest {
|
.collect {
|
||||||
withUIContext {
|
withUIContext {
|
||||||
updateDownloadState(it)
|
updateDownloadState(it)
|
||||||
}
|
}
|
||||||
@ -429,7 +429,7 @@ class MangaPresenter(
|
|||||||
downloadManager.queue.getProgressAsFlow()
|
downloadManager.queue.getProgressAsFlow()
|
||||||
.filter { it.manga.id == successState?.manga?.id }
|
.filter { it.manga.id == successState?.manga?.id }
|
||||||
.catch { error -> logcat(LogPriority.ERROR, error) }
|
.catch { error -> logcat(LogPriority.ERROR, error) }
|
||||||
.collectLatest {
|
.collect {
|
||||||
withUIContext {
|
withUIContext {
|
||||||
updateDownloadState(it)
|
updateDownloadState(it)
|
||||||
}
|
}
|
||||||
|
@ -157,7 +157,7 @@ class UpdatesPresenter(
|
|||||||
observeDownloadsStatusJob = presenterScope.launchIO {
|
observeDownloadsStatusJob = presenterScope.launchIO {
|
||||||
downloadManager.queue.getStatusAsFlow()
|
downloadManager.queue.getStatusAsFlow()
|
||||||
.catch { error -> logcat(LogPriority.ERROR, error) }
|
.catch { error -> logcat(LogPriority.ERROR, error) }
|
||||||
.collectLatest {
|
.collect {
|
||||||
withUIContext {
|
withUIContext {
|
||||||
updateDownloadState(it)
|
updateDownloadState(it)
|
||||||
}
|
}
|
||||||
@ -168,7 +168,7 @@ class UpdatesPresenter(
|
|||||||
observeDownloadsPageJob = presenterScope.launchIO {
|
observeDownloadsPageJob = presenterScope.launchIO {
|
||||||
downloadManager.queue.getProgressAsFlow()
|
downloadManager.queue.getProgressAsFlow()
|
||||||
.catch { error -> logcat(LogPriority.ERROR, error) }
|
.catch { error -> logcat(LogPriority.ERROR, error) }
|
||||||
.collectLatest {
|
.collect {
|
||||||
withUIContext {
|
withUIContext {
|
||||||
updateDownloadState(it)
|
updateDownloadState(it)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user