null2264/yokai
1
0
Fork 0
mirror of https://github.com/null2264/yokai.git synced 2025-06-21 10:44:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(DownloadQueue): Fix ConcurrentModificationException

Browse source
This commit is contained in:
Ahmad Ansori Palembani 2024-12-03 07:33:03 +07:00
parent b9f7d18d3d
commit ea9407b49d
Signed by: null2264
GPG key ID: BA64F8B60AF3EFB6
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
app/src/main/java/eu/kanade/tachiyomi/data/download/model/DownloadQueue.kt
View file

@ -43,7 +43,7 @@ class DownloadQueue(
if (download.status == Download.State.DOWNLOADING || download.status == Download.State.QUEUE) { if (download.status == Download.State.DOWNLOADING || download.status == Download.State.QUEUE) {
download.status = Download.State.NOT_DOWNLOADED download.status = Download.State.NOT_DOWNLOADED
} }
downloadListeners.forEach { it.updateDownload(download) } callListeners(download)
if (removed) { if (removed) {
updatedRelay.call(Unit) updatedRelay.call(Unit)
} }
@ -73,7 +73,7 @@ class DownloadQueue(
if (download.status == Download.State.DOWNLOADING || download.status == Download.State.QUEUE) { if (download.status == Download.State.DOWNLOADING || download.status == Download.State.QUEUE) {
download.status = Download.State.NOT_DOWNLOADED download.status = Download.State.NOT_DOWNLOADED
} }
downloadListeners.forEach { it.updateDownload(download) } callListeners(download)
} }
queue.clear() queue.clear()
store.clear() store.clear()
@ -102,7 +102,10 @@ class DownloadQueue(
} }
private fun callListeners(download: Download) { private fun callListeners(download: Download) {
downloadListeners.forEach { it.updateDownload(download) } val iterator = downloadListeners.iterator()
while (iterator.hasNext()) {
iterator.next().updateDownload(download)
}
} }
// private fun setPagesSubject(pages: List<Page>?, subject: PublishSubject<Int>?) { // private fun setPagesSubject(pages: List<Page>?, subject: PublishSubject<Int>?) {