mirror of
https://github.com/Aviortheking/Neo-Store.git
synced 2025-04-24 11:52:13 +00:00
Fix: Allow retention of apk till "consumed" (closes #260)
This commit is contained in:
parent
cb94485e82
commit
3861582d66
@ -30,6 +30,7 @@ import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers
|
|||||||
import io.reactivex.rxjava3.disposables.Disposable
|
import io.reactivex.rxjava3.disposables.Disposable
|
||||||
import kotlinx.coroutines.CoroutineScope
|
import kotlinx.coroutines.CoroutineScope
|
||||||
import kotlinx.coroutines.Dispatchers
|
import kotlinx.coroutines.Dispatchers
|
||||||
|
import kotlinx.coroutines.MainScope
|
||||||
import kotlinx.coroutines.cancel
|
import kotlinx.coroutines.cancel
|
||||||
import kotlinx.coroutines.flow.MutableSharedFlow
|
import kotlinx.coroutines.flow.MutableSharedFlow
|
||||||
import kotlinx.coroutines.flow.asSharedFlow
|
import kotlinx.coroutines.flow.asSharedFlow
|
||||||
@ -194,12 +195,12 @@ class DownloadService : ConnectionService<DownloadService.Binder>() {
|
|||||||
mutableStateSubject.emit(State.Success(task.packageName, task.name, task.release))
|
mutableStateSubject.emit(State.Success(task.packageName, task.name, task.release))
|
||||||
consumed = true
|
consumed = true
|
||||||
}
|
}
|
||||||
//if (!consumed) { TODO investigate if there's resulting issues
|
if (!consumed) { //TODO investigate if there's resulting issues
|
||||||
scope.launch {
|
MainScope().launch {
|
||||||
AppInstaller.getInstance(this@DownloadService)
|
AppInstaller.getInstance(this@DownloadService)
|
||||||
?.defaultInstaller?.install(task.name, task.release.cacheFileName)
|
?.defaultInstaller?.install(task.name, task.release.cacheFileName)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
//}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun validatePackage(task: Task, file: File): ValidationError? {
|
private fun validatePackage(task: Task, file: File): ValidationError? {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user