onErrorReturn.kt

Observable.fromArray(1,2,3)
        .doOnNext {
            if(it==2){
                throw (RuntimeException("Exception on 2"))
            }
        }
        .onErrorReturn{
            t: Throwable ->
            if(t.message=="<something you want>"){
                1 // Return a value based on error type
            }else{
                100 // Return another value based on different error type
            }
        }
        .subscribeBy(
        onNext = {
            println(it)
        },onError = {
            println(it.message)
        },onComplete = {
            println("Complete")
        }
)