Rx2Test.kt

Completable.complete()
              .subscribe(
                    Action { throw exception },
                    Consumer { /* wont be called */ }
              )


Observable.just(str)
              .subscribe(
                    Consumer { throw exception },
                    Consumer { /* will be called */ }
              )