From f819202b6dd1a3ed2a99f6593715d79c21d2e5b1 Mon Sep 17 00:00:00 2001
From: Horis <821938089@qq.com>
Date: Sun, 17 Dec 2023 14:36:48 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../io/legado/app/model/analyzeRule/AnalyzeUrl.kt    | 12 ++----------
 1 file changed, 2 insertions(+), 10 deletions(-)

diff --git a/app/src/main/java/io/legado/app/model/analyzeRule/AnalyzeUrl.kt b/app/src/main/java/io/legado/app/model/analyzeRule/AnalyzeUrl.kt
index 327e1b033..7dd1d7aa2 100644
--- a/app/src/main/java/io/legado/app/model/analyzeRule/AnalyzeUrl.kt
+++ b/app/src/main/java/io/legado/app/model/analyzeRule/AnalyzeUrl.kt
@@ -343,7 +343,7 @@ class AnalyzeUrl(
                     if (fetchRecord.frequency > cs.toInt()) {
                         return@synchronized (nextTime - System.currentTimeMillis()).toInt()
                     } else {
-                        fetchRecord.frequency = fetchRecord.frequency + 1
+                        fetchRecord.frequency += 1
                         return@synchronized 0
                     }
                 }
@@ -366,7 +366,7 @@ class AnalyzeUrl(
     private fun fetchEnd(concurrentRecord: ConcurrentRecord?) {
         if (concurrentRecord != null && !concurrentRecord.isConcurrent) {
             synchronized(concurrentRecord) {
-                concurrentRecord.frequency = concurrentRecord.frequency - 1
+                concurrentRecord.frequency -= 1
             }
         }
     }
@@ -387,7 +387,6 @@ class AnalyzeUrl(
     /**
      * 访问网站,返回StrResponse
      */
-    @Throws(ConcurrentException::class)
     suspend fun getStrResponseAwait(
         jsStr: String? = null,
         sourceRegex: String? = null,
@@ -466,7 +465,6 @@ class AnalyzeUrl(
     }
 
     @JvmOverloads
-    @Throws(ConcurrentException::class)
     fun getStrResponse(
         jsStr: String? = null,
         sourceRegex: String? = null,
@@ -480,7 +478,6 @@ class AnalyzeUrl(
     /**
      * 访问网站,返回Response
      */
-    @Throws(ConcurrentException::class)
     suspend fun getResponseAwait(): Response {
         val concurrentRecord = getConcurrentRecord()
         try {
@@ -512,7 +509,6 @@ class AnalyzeUrl(
         }
     }
 
-    @Throws(ConcurrentException::class)
     fun getResponse(): Response {
         return runBlocking {
             getResponseAwait()
@@ -520,7 +516,6 @@ class AnalyzeUrl(
     }
 
     @Suppress("UnnecessaryVariable")
-    @Throws(ConcurrentException::class)
     private fun getByteArrayIfDataUri(): ByteArray? {
         @Suppress("RegExpRedundantEscape")
         val dataUriFindResult = dataUriRegex.find(urlNoQuery)
@@ -535,7 +530,6 @@ class AnalyzeUrl(
     /**
      * 访问网站,返回ByteArray
      */
-    @Throws(ConcurrentException::class)
     suspend fun getByteArrayAwait(): ByteArray {
         getByteArrayIfDataUri()?.let {
             return it
@@ -552,7 +546,6 @@ class AnalyzeUrl(
     /**
      * 访问网站,返回InputStream
      */
-    @Throws(ConcurrentException::class)
     suspend fun getInputStreamAwait(): InputStream {
         getByteArrayIfDataUri()?.let {
             return ByteArrayInputStream(it)
@@ -560,7 +553,6 @@ class AnalyzeUrl(
         return getResponseAwait().body!!.byteStream()
     }
 
-    @Throws(ConcurrentException::class)
     fun getInputStream(): InputStream {
         return runBlocking {
             getInputStreamAwait()