doOnError.kt

Observable.fromArray(1,2,3)
        .doOnNext {
            if(it==2){
                throw (RuntimeException("Exception on 2"))
            }
        }
        .doOnError {
            println("Doing on error")
        }
        .subscribeBy(
        onNext = {
            println(it)
        },onError = {
            println(it.message)
        },onComplete = {
            println("Complete")
        }
)