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 1ffe08d commit 670cc0aCopy full SHA for 670cc0a
driver-scala/src/main/scala/org/mongodb/scala/ObservableImplicits.scala
@@ -95,10 +95,7 @@ trait ObservableImplicits {
95
subscription.request(1)
96
}
97
98
- override def onError(throwable: Throwable): Unit = throwable match {
99
- case npe: NullPointerException => onComplete()
100
- case _ => completeWith("onError", () => observer.onError(throwable))
101
- }
+ override def onError(throwable: Throwable): Unit = completeWith("onError", () => observer.onError(throwable))
102
103
override def onComplete(): Unit = {
104
completeWith("onComplete", { () =>
0 commit comments