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 b1112d0 commit 5b167c0Copy full SHA for 5b167c0
src/main/kotlin/rx/lang/kotlin/subscribers.kt
@@ -4,9 +4,10 @@ import rx.Completable
4
import rx.Observable
5
import rx.Single
6
import rx.Subscription
7
+import rx.exceptions.OnErrorNotImplementedException
8
9
private val onNextStub: (Any) -> Unit = {}
-private val onErrorStub: (Throwable) -> Unit = {}
10
+private val onErrorStub: (Throwable) -> Unit = { throw OnErrorNotImplementedException(it) }
11
private val onCompleteStub: () -> Unit = {}
12
13
/**
0 commit comments