athaliar/APKDownloader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

DownloadWorkerUtil: Properly collect flow to cancel downloads

Browse Source 
Signed-off-by: Aayush Gupta <aayushgupta219@gmail.com>
This commit is contained in:
Aayush Gupta
2023-12-27 21:00:12 +05:30
parent 87dc309d35
commit 96c10df255
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
app/src/main/java/com/aurora/store/util/DownloadWorkerUtil.kt
View File

@@ -21,6 +21,8 @@ import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.cancel import kotlinx.coroutines.cancel
import kotlinx.coroutines.flow.SharingStarted import kotlinx.coroutines.flow.SharingStarted
import kotlinx.coroutines.flow.collectLatest import kotlinx.coroutines.flow.collectLatest
import kotlinx.coroutines.flow.filter
import kotlinx.coroutines.flow.firstOrNull
import kotlinx.coroutines.flow.stateIn import kotlinx.coroutines.flow.stateIn
import kotlinx.coroutines.launch import kotlinx.coroutines.launch
@@ -80,8 +82,8 @@ class DownloadWorkerUtil @Inject constructor(
suspend fun cancelDownload(packageName: String) { suspend fun cancelDownload(packageName: String) {
Log.i(TAG, "Cancelling download for $packageName") Log.i(TAG, "Cancelling download for $packageName")
WorkManager.getInstance(context).cancelAllWorkByTag("$PACKAGE_NAME:$packageName") WorkManager.getInstance(context).cancelAllWorkByTag("$PACKAGE_NAME:$packageName")
downloadsList.value downloadsList.filter { it.isNotEmpty() }.firstOrNull()
.find { it.packageName == packageName && it.status == DownloadStatus.QUEUED } ?.find { it.packageName == packageName && it.status == DownloadStatus.QUEUED }
?.let { downloadDao.update(it.copy(status = DownloadStatus.CANCELLED)) } ?.let { downloadDao.update(it.copy(status = DownloadStatus.CANCELLED)) }
} }