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

Remove a Jvm specific function

Browse Source
This commit is contained in:
Syer10
2022-11-15 22:00:45 -05:00
parent d8100ee309
commit ac04b034dd
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
presentation/src/commonMain/kotlin/ca/gosyer/jui/ui/reader/loader/TachideskPageLoader.kt
View File

@@ -15,6 +15,7 @@ import ca.gosyer.jui.ui.base.model.StableHolder
import ca.gosyer.jui.ui.reader.model.ReaderChapter import ca.gosyer.jui.ui.reader.model.ReaderChapter
import ca.gosyer.jui.ui.reader.model.ReaderPage import ca.gosyer.jui.ui.reader.model.ReaderPage
import ca.gosyer.jui.ui.util.compose.asImageBitmap import ca.gosyer.jui.ui.util.compose.asImageBitmap
import ca.gosyer.jui.ui.util.lang.toSource
import cafe.adriel.voyager.core.concurrent.AtomicInt32 import cafe.adriel.voyager.core.concurrent.AtomicInt32
import com.seiko.imageloader.cache.disk.DiskCache import com.seiko.imageloader.cache.disk.DiskCache
import com.seiko.imageloader.component.decoder.DecodeImageResult import com.seiko.imageloader.component.decoder.DecodeImageResult
@@ -23,7 +24,6 @@ import com.seiko.imageloader.request.Options
import com.seiko.imageloader.request.SourceResult import com.seiko.imageloader.request.SourceResult
import io.ktor.client.plugins.onDownload import io.ktor.client.plugins.onDownload
import io.ktor.client.statement.bodyAsChannel import io.ktor.client.statement.bodyAsChannel
import io.ktor.utils.io.jvm.javaio.toInputStream
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.SupervisorJob import kotlinx.coroutines.SupervisorJob
@@ -39,7 +39,6 @@ import kotlinx.coroutines.launch
import okio.BufferedSource import okio.BufferedSource
import okio.FileSystem import okio.FileSystem
import okio.buffer import okio.buffer
import okio.source
import org.lighthousegames.logging.logging import org.lighthousegames.logging.logging
class TachideskPageLoader( class TachideskPageLoader(
@@ -78,9 +77,9 @@ class TachideskPageLoader(
try { try {
for (priorityPage in channel) { for (priorityPage in channel) {
val page = priorityPage.page val page = priorityPage.page
log.debug { "Loading page ${page.index}" }
if (page.status.value == ReaderPage.Status.QUEUE) { if (page.status.value == ReaderPage.Status.QUEUE) {
page.status.value = ReaderPage.Status.WORKING page.status.value = ReaderPage.Status.WORKING
log.debug { "Loading page ${page.index}" }
getChapterPage.asFlow(chapter.chapter, page.index) { getChapterPage.asFlow(chapter.chapter, page.index) {
onDownload { bytesSentTotal, contentLength -> onDownload { bytesSentTotal, contentLength ->
page.progress.value = (bytesSentTotal.toFloat() / contentLength).coerceAtMost(1.0F) page.progress.value = (bytesSentTotal.toFloat() / contentLength).coerceAtMost(1.0F)
@@ -91,7 +90,7 @@ class TachideskPageLoader(
?: throw Exception("Couldn't open cache") ?: throw Exception("Couldn't open cache")
try { try {
FileSystem.SYSTEM.write(editor.data) { FileSystem.SYSTEM.write(editor.data) {
it.bodyAsChannel().toInputStream().source().use { it.bodyAsChannel().toSource().use {
writeAll(it) writeAll(it)
} }
} }