From cfa613b5db7614cc3471a1b0f0a45139ab2d5601 Mon Sep 17 00:00:00 2001
From: Jason Yao <h11129@gmail.com>
Date: Fri, 20 Aug 2021 21:07:19 -0400
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0timeout?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../app/ui/book/source/manage/BookSourceActivity.kt       | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/app/src/main/java/io/legado/app/ui/book/source/manage/BookSourceActivity.kt b/app/src/main/java/io/legado/app/ui/book/source/manage/BookSourceActivity.kt
index b16753e0a..4db5082bd 100644
--- a/app/src/main/java/io/legado/app/ui/book/source/manage/BookSourceActivity.kt
+++ b/app/src/main/java/io/legado/app/ui/book/source/manage/BookSourceActivity.kt
@@ -44,6 +44,7 @@ import io.legado.app.utils.viewbindingdelegate.viewBinding
 import kotlinx.coroutines.*
 import kotlinx.coroutines.flow.*
 import java.io.File
+import kotlin.math.min
 
 class BookSourceActivity : VMBaseActivity<ActivityBookSourceBinding, BookSourceViewModel>(),
     PopupMenu.OnMenuItemClickListener,
@@ -457,16 +458,19 @@ class BookSourceActivity : VMBaseActivity<ActivityBookSourceBinding, BookSourceV
     private fun checkMessageRefreshJob(): Job {
         val firstIndex = adapter.getItems().indexOf(adapter.selection.first())
         val lastIndex = adapter.getItems().indexOf(adapter.selection.last())
+        var refreshCount = 0
         Debug.isChecking = true
         return async(start = CoroutineStart.LAZY) {
             flow {
                 while (true) {
-                    emit(Debug.isChecking)
+                    refreshCount += 1
+                    emit(refreshCount)
                     delay(300L)
                 }
             }.collect {
                 adapter.notifyItemRangeChanged(firstIndex, lastIndex + 1, bundleOf(Pair("checkSourceMessage", null)))
-                if (!it) {
+                if (!Debug.isChecking || (refreshCount > (600 * (lastIndex + 1 - firstIndex) / min(AppConfig.threadCount,8)))) {
+                    Debug.finishChecking()
                     this.cancel()
                 }
             }