|
@@ -19,6 +19,7 @@ import io.legado.app.utils.activityPendingIntent
|
|
|
import io.legado.app.utils.postEvent
|
|
import io.legado.app.utils.postEvent
|
|
|
import io.legado.app.utils.servicePendingIntent
|
|
import io.legado.app.utils.servicePendingIntent
|
|
|
import io.legado.app.utils.toastOnUi
|
|
import io.legado.app.utils.toastOnUi
|
|
|
|
|
+import kotlinx.coroutines.Dispatchers.IO
|
|
|
import kotlinx.coroutines.asCoroutineDispatcher
|
|
import kotlinx.coroutines.asCoroutineDispatcher
|
|
|
import java.util.concurrent.Executors
|
|
import java.util.concurrent.Executors
|
|
|
import kotlin.math.min
|
|
import kotlin.math.min
|
|
@@ -204,8 +205,9 @@ class CheckSourceService : BaseService() {
|
|
|
"" else "\n\n${source.bookSourceComment}"
|
|
"" else "\n\n${source.bookSourceComment}"
|
|
|
Debug.updateFinalMessage(source.bookSourceUrl, "校验失败:${it.localizedMessage}")
|
|
Debug.updateFinalMessage(source.bookSourceUrl, "校验失败:${it.localizedMessage}")
|
|
|
}.onSuccess(searchCoroutine) {
|
|
}.onSuccess(searchCoroutine) {
|
|
|
|
|
+ source.removeGroup("失效")
|
|
|
Debug.updateFinalMessage(source.bookSourceUrl, "校验成功")
|
|
Debug.updateFinalMessage(source.bookSourceUrl, "校验成功")
|
|
|
- }.onFinally(searchCoroutine) {
|
|
|
|
|
|
|
+ }.onFinally(IO) {
|
|
|
source.respondTime = Debug.getRespondTime(source.bookSourceUrl)
|
|
source.respondTime = Debug.getRespondTime(source.bookSourceUrl)
|
|
|
appDb.bookSourceDao.update(source)
|
|
appDb.bookSourceDao.update(source)
|
|
|
onNext(source.bookSourceUrl, source.bookSourceName)
|
|
onNext(source.bookSourceUrl, source.bookSourceName)
|