Catch Throwable instead of Exception in Rx3 asFlow

LouisCAD · web-flow · commit f756f04b3f7d · 2020-10-20T11:02:01.000+02:00
diff --git a/reactive/kotlinx-coroutines-rx3/src/RxConvert.kt b/reactive/kotlinx-coroutines-rx3/src/RxConvert.kt
@@ -84,7 +84,7 @@ public fun <T: Any> ObservableSource<T>.asFlow(): Flow<T> = callbackFlow {
         override fun onNext(t: T) {
             try {
                 sendBlocking(t)
-            } catch (ignored: Exception) { //TODO: Replace when this issue is fixed: https://github.com/Kotlin/kotlinx.coroutines/issues/974
+            } catch (ignored: Throwable) { //TODO: Replace when this issue is fixed: https://github.com/Kotlin/kotlinx.coroutines/issues/974
             }
         }
         override fun onError(e: Throwable) { close(e) }

Original file line number	Diff line number	Diff line change
`@@ -84,7 +84,7 @@ public fun <T: Any> ObservableSource<T>.asFlow(): Flow<T> = callbackFlow {`
`84`	`84`	`override fun onNext(t: T) {`
`85`	`85`	`try {`
`86`	`86`	`sendBlocking(t)`
`87`		`- } catch (ignored: Exception) { //TODO: Replace when this issue is fixed: https://github.com/Kotlin/kotlinx.coroutines/issues/974`
	`87`	`+ } catch (ignored: Throwable) { //TODO: Replace when this issue is fixed: https://github.com/Kotlin/kotlinx.coroutines/issues/974`
`88`	`88`	`}`
`89`	`89`	`}`
`90`	`90`	`override fun onError(e: Throwable) { close(e) }`