We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b41e51a commit 13aea06Copy full SHA for 13aea06
1 file changed
core/src/commonMain/kotlin/Observers.kt
@@ -67,6 +67,8 @@ internal class Observers<T>(
67
.onSubscription {
68
try {
69
observation.onSubscription(onSubscription)
70
+ } catch (e: CancellationException) {
71
+ throw e
72
} catch (e: Exception) {
73
exceptionHandler(ObservationExceptionPeripheral(peripheral), e)
74
}
@@ -80,6 +82,8 @@ internal class Observers<T>(
80
82
.onCompletion {
81
83
84
observation.onCompletion(onSubscription)
85
86
87
88
89
0 commit comments