Skip to content

Instantly share code, notes, and snippets.

@aanandshekharroy
Created February 12, 2018 17:03
Show Gist options
  • Save aanandshekharroy/9a03814f1e49839133b13558894f2ea4 to your computer and use it in GitHub Desktop.
Save aanandshekharroy/9a03814f1e49839133b13558894f2ea4 to your computer and use it in GitHub Desktop.
Observable.fromArray(1,2,3)
.doOnNext {
if(it==2){
throw (RuntimeException("Exception on 2"))
}
}
.onErrorReturnItem (-1)
.subscribeBy(
onNext = {
println(it)
},onError = {
println(it.message)
},onComplete = {
println("Complete")
}
)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment