使用协程时无法捕获网络错误,但错误可能在 RxJava 2 中捕获。我错过了什么?
Can't catch network error when using coroutine, but the error could be caught in RxJava 2. What did I miss?
我有以下代码使用协程在后台执行网络抓取
try {
networkJob = CoroutineScope(Dispatchers.IO).launch {
val result = fetchOnBackground(searchText)
withContext(Dispatchers.Main) {
showResult("Count is $result")
}
}
} catch (exception: Throwable) {
showResult(exception.localizedMessage)
}
只要有网络,一切都很好。但是,当主机不正确或没有网络时,它会崩溃。 catch
抓不住
当我使用 RxJava 编码时
disposable = Single.just(searchText)
.map{fetchOnBackground(it)}
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
{ showResult("Count is $it") },
{ showResult(it.localizedMessage) })
一切正常。即使在没有网络的情况下,错误也会在错误回调中被捕获。
我在协程代码中遗漏了什么,在使用协程时无法在我这边捕获错误?
注意:网络抓取使用的是OkHttp。
似乎我需要将 try-catch
放在 CouroutineScope(Dispatchers.IO).launch
中
networkJob = CoroutineScope(Dispatchers.IO).launch {
try {
val result = fetchOnBackground(searchText)
showResult("Count is $result")
} catch (exception: Throwable) {
showResult(exception.localizedMessage)
}
}
然后我将 showResult
更改为暂停函数,这样它就可以包含 withContext(Dispatchers.Main)
private suspend fun showResult(result: String) {
withContext(Dispatchers.Main) {
// Code that show the result
}
}
我有以下代码使用协程在后台执行网络抓取
try {
networkJob = CoroutineScope(Dispatchers.IO).launch {
val result = fetchOnBackground(searchText)
withContext(Dispatchers.Main) {
showResult("Count is $result")
}
}
} catch (exception: Throwable) {
showResult(exception.localizedMessage)
}
只要有网络,一切都很好。但是,当主机不正确或没有网络时,它会崩溃。 catch
抓不住
当我使用 RxJava 编码时
disposable = Single.just(searchText)
.map{fetchOnBackground(it)}
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
{ showResult("Count is $it") },
{ showResult(it.localizedMessage) })
一切正常。即使在没有网络的情况下,错误也会在错误回调中被捕获。
我在协程代码中遗漏了什么,在使用协程时无法在我这边捕获错误?
注意:网络抓取使用的是OkHttp。
似乎我需要将 try-catch
放在 CouroutineScope(Dispatchers.IO).launch
networkJob = CoroutineScope(Dispatchers.IO).launch {
try {
val result = fetchOnBackground(searchText)
showResult("Count is $result")
} catch (exception: Throwable) {
showResult(exception.localizedMessage)
}
}
然后我将 showResult
更改为暂停函数,这样它就可以包含 withContext(Dispatchers.Main)
private suspend fun showResult(result: String) {
withContext(Dispatchers.Main) {
// Code that show the result
}
}