Wrap OnErrorNotImplementedException (ReactiveX#100)

cloudbank · Mar 14, 2017 · 5b167c0 · 5b167c0
1 parent b1112d0
commit 5b167c0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/kotlin/rx/lang/kotlin/subscribers.kt b/src/main/kotlin/rx/lang/kotlin/subscribers.kt
@@ -4,9 +4,10 @@ import rx.Completable
 import rx.Observable
 import rx.Single
 import rx.Subscription
+import rx.exceptions.OnErrorNotImplementedException
 
 private val onNextStub: (Any) -> Unit = {}
-private val onErrorStub: (Throwable) -> Unit = {}
+private val onErrorStub: (Throwable) -> Unit = { throw OnErrorNotImplementedException(it) }
 private val onCompleteStub: () -> Unit = {}
 
 /**