how can RxJava v2 throw an exception to be handled...

# rx

[zak.taccardi]

how can RxJava v2 throw an exception to be handled imperatively? Is it possible? I'm current getting a fatal ERR: stack=java.lang.NullPointerException: subscribeActual failed

@Throws(Throwable::class)
    override fun onRun() {
              //synchronous stream....
                .subscribe(
                        {},
                        { throw it } //I need this exception to be thrown to the wrapping `onRun` method
                )
    }

[Zach Klippenstein (he/him) [MOD]]

@zak.taccardi: toBlocking().subscribe(), although beware toBlocking(). http://reactivex.io/RxJava/javadoc/rx/observables/BlockingObservable.html#subscribe()