mirrors/TachideskJUI
1
0
Fork 0
mirror of https://github.com/Suwayomi/TachideskJUI.git synced 2025-12-10 06:42:05 +01:00
Code Issues Projects Releases Wiki Activity

Automatic Lint

Browse Source
This commit is contained in:
Syer10
2023-02-12 23:05:39 +00:00
parent 054b977604
commit c70be391b4
5 changed files with 31 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
domain/src/commonMain/kotlin/ca/gosyer/jui/domain/manga/model/Manga.kt
View File

@@ -74,4 +74,4 @@ enum class MangaStatus(@Transient val res: StringResource) {
enum class UpdateStrategy {
ALWAYS_UPDATE,
ONLY_FETCH_ONCE
}
}

10
domain/src/commonMain/kotlin/ca/gosyer/jui/domain/updates/interactor/UpdatesPager.kt
View File

@@ -41,8 +41,8 @@ class UpdatesPager @Inject constructor(
private val getRecentUpdates: GetRecentUpdates,
private val getManga: GetManga,
private val getChapter: GetChapter,
private val serverListeners: ServerListeners,
) : CoroutineScope by CoroutineScope(Dispatchers.Default + SupervisorJob()){
private val serverListeners: ServerListeners
) : CoroutineScope by CoroutineScope(Dispatchers.Default + SupervisorJob()) {
private val updatesMutex = Mutex()
private val fetchedUpdates = MutableSharedFlow<List<MangaAndChapter>>()
@@ -96,7 +96,7 @@ class UpdatesPager @Inject constructor(
init {
serverListeners.chapterIndexesListener
.onEach {(mangaId, chapterIndexes) ->
.onEach { (mangaId, chapterIndexes) ->
if (chapterIndexes == null) {
val chapters = coroutineScope {
foldedUpdates.value.filterIsInstance<Updates.Update>().filter { it.manga.id == mangaId }.map {
@@ -133,7 +133,6 @@ class UpdatesPager @Inject constructor(
.launchIn(this)
}
val updates = combine(
foldedUpdates,
changedManga,
@@ -157,6 +156,7 @@ class UpdatesPager @Inject constructor(
sealed class Updates {
@Immutable
data class Update(val manga: Manga, val chapter: Chapter) : Updates()
@Immutable
data class Date(val date: String) : Updates() {
constructor(date: LocalDate) : this(date.toString())
@@ -185,4 +185,4 @@ class UpdatesPager @Inject constructor(
fetchedUpdates.emit(updates.page)
return true
}
}
}