Draff/TachiyomiSY-Plus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Always retry when its a NPE

Browse Source
This commit is contained in:
Jobobby04 2023-05-06 18:58:06 -04:00
parent f1bb886737
commit 3a5e23550f
2 changed files with 16 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
domain/src/main/java/tachiyomi/domain/manga/interactor/GetLibraryManga.kt
View File

@ -1,10 +1,11 @@
package tachiyomi.domain.manga.interactor
import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.onEach
import kotlinx.coroutines.flow.retry
import tachiyomi.domain.library.model.LibraryManga
import tachiyomi.domain.manga.repository.MangaRepository
import kotlin.time.Duration.Companion.seconds
class GetLibraryManga(
private val mangaRepository: MangaRepository,
@ -17,12 +18,12 @@ class GetLibraryManga(
fun subscribe(): Flow<List<LibraryManga>> {
return mangaRepository.getLibraryMangaAsFlow()
// SY -->
.let {
var retries = 0
it.retry {
(retries++ < 3) && it is NullPointerException
}.onEach {
retries = 0
.retry {
if (it is NullPointerException) {
delay(5.seconds)
true
} else {
false
}
}
// SY <--

15
domain/src/main/java/tachiyomi/domain/updates/interactor/GetUpdates.kt
View File

@ -1,11 +1,12 @@
package tachiyomi.domain.updates.interactor
import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.onEach
import kotlinx.coroutines.flow.retry
import tachiyomi.domain.updates.model.UpdatesWithRelations
import tachiyomi.domain.updates.repository.UpdatesRepository
import java.util.Calendar
import kotlin.time.Duration.Companion.seconds
class GetUpdates(
private val repository: UpdatesRepository,
@ -20,12 +21,12 @@ class GetUpdates(
fun subscribe(after: Long): Flow<List<UpdatesWithRelations>> {
return repository.subscribeAll(after)
// SY -->
.let {
var retries = 0
it.retry {
(retries++ < 3) && it is NullPointerException
}.onEach {
retries = 0
.retry {
if (it is NullPointerException) {
delay(5.seconds)
true
} else {
false
}
}
// SY <--