update

app/src/main/java/io/legado/app/base/BaseViewModel.kt

@@ -4,6 +4,7 @@ import android.app.Application
 import androidx.lifecycle.AndroidViewModel
 import io.legado.app.help.coroutine.Coroutine
 import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Deferred
 import kotlinx.coroutines.MainScope
 import kotlinx.coroutines.cancel
 import org.jetbrains.anko.AnkoLogger
@@ -11,10 +12,15 @@ import org.jetbrains.anko.AnkoLogger
 open class BaseViewModel(application: Application) : AndroidViewModel(application), CoroutineScope by MainScope(),
     AnkoLogger {
 
-    fun <T> execute(domain: suspend CoroutineScope.() -> T): Coroutine<T> {
+    fun <T> execute(block: suspend CoroutineScope.() -> T): Coroutine<T> {
-        return Coroutine.with(this) { domain() }
+        return Coroutine.with(this) { block() }
     }
 
+    fun <T> submit(block: suspend CoroutineScope.() -> Deferred<T>): Coroutine<T> {
+        return Coroutine.with(this) { block().await() }
+    }
+
+
     override fun onCleared() {
         super.onCleared()
         cancel()

app/src/main/java/io/legado/app/help/permission/Request.kt

@@ -127,19 +127,21 @@ internal class Request : OnRequestPermissionsResultCallback {
     private fun showSettingDialog(rationale: CharSequence, cancel: () -> Unit) {
         rationaleDialog?.dismiss()
         source?.context?.let {
-            rationaleDialog = AlertDialog.Builder(it)
+            runCatching {
-                .setTitle(R.string.dialog_title)
+                rationaleDialog = AlertDialog.Builder(it)
-                .setMessage(rationale)
+                    .setTitle(R.string.dialog_title)
-                .setPositiveButton(R.string.dialog_setting) { _, _ ->
+                    .setMessage(rationale)
-                    it.startActivity<PermissionActivity>(
+                    .setPositiveButton(R.string.dialog_setting) { _, _ ->
-                        Pair(
+                        it.startActivity<PermissionActivity>(
-                            PermissionActivity.KEY_INPUT_REQUEST_TYPE,
+                            Pair(
-                            TYPE_REQUEST_SETTING
+                                PermissionActivity.KEY_INPUT_REQUEST_TYPE,
+                                TYPE_REQUEST_SETTING
+                            )
                         )
-                    )
+                    }
-                }
+                    .setNegativeButton(R.string.dialog_cancel) { _, _ -> cancel() }
-                .setNegativeButton(R.string.dialog_cancel) { _, _ -> cancel() }
+                    .show()
-                .show()
+            }
         }
     }
 

app/src/main/java/io/legado/app/ui/search/SearchViewModel.kt

@@ -9,34 +9,44 @@ import io.legado.app.data.api.CommonHttpApi
 import io.legado.app.data.entities.SearchBook
 import io.legado.app.help.http.HttpHelper
 import kotlinx.coroutines.delay
+import kotlinx.coroutines.launch
+
 
 class SearchViewModel(application: Application) : BaseViewModel(application) {
 
     val searchBooks: LiveData<List<SearchBook>> = MutableLiveData()
 
     fun search(start: (() -> Unit)? = null, finally: (() -> Unit)? = null) {
-        execute {
+        launch {
-            val response: String = HttpHelper.getApiService<CommonHttpApi>(
+            delay(1000L)
-                "http://www.baidu.com"
-            ).get("http://www.baidu.com").await()
 
-            delay(4000L)
 
-            Log.e("TAG1", Thread.currentThread().name)
+            repeat(100) {
+                test(it)
+            }
 
-            response
+        }
+    }
 
+
+    private fun test(index: Int) {
+        submit {
+            val response = HttpHelper.getApiService<CommonHttpApi>(
+                "http://www.baidu.com"
+            ).get("http://www.baidu.com")
+
+            Log.e("TAG", "next: $index")
+
+            response
         }
-            .timeout { 100L }
-            .onErrorReturn { "error return" }
             .onStart {
-                Log.e("TAG!", "start")
+                Log.e("TAG!", "start: $index")
             }
             .onSuccess {
-                Log.e("TAG!", "success: $it")
+                Log.e("TAG!", "success: $index --> $it")
             }
             .onError {
-                Log.e("TAG!", "error: $it")
+                Log.e("TAG!", "error: $index --> $it")
             }
             .onFinally {
                 Log.e("TAG!", "finally")