Exception in subscribe's onNext is not rethrown

[dvtomas]

import rx.lang.scala.Observable
Observable.items(1, 2, 3).subscribe(next ⇒ throw new RuntimeException("Bang!"))

I'm still trying to grasp all the nuances of the Rx Contract, but according to various sources (for one, http://social.msdn.microsoft.com/Forums/en-US/6ea06e08-6d26-49b4-a3fa-276d1efef780/what-if-an-exception-is-thrown-by-the-observer-in-onnext?forum=rx), I'd expect this code snippet to throw the Bang exception, but it does (as of Rx 0.16.1) not. However, such issue seems too basic to me to go unnoticed, so I guess there is some reason for such behavior. Can someone elaborate, please?

Thank you,
Tomáš Dvořák

[zsxwing]

Your Bang exception should be sent to onError method. But you do not pass the onError function. So an OnErrorNotImplementedException should be thrown. However, as the issue #771, the OnErrorNotImplementedException will be swallowed. Once the issue is fixed, you will observe OnErrorNotImplementedException.

[benjchristensen]

Dealing with in pull request #839

[benjchristensen]

Should be fixed in #839