サンプルコード
subject.subscribe ({ number ->
println(number.toString())
if (number == 3) throw RuntimeException()
}, {
println("onError")
}, {
println("onComplete")
})
subject.onNext(1)
subject.onNext(2)
subject.onNext(3)
subject.onNext(4)
subject.onNext(5)
実行結果
1
2
3
onError
4と5が表示されない。
所感
onErrorに入った時にちゃんと気がつけないと、何故かいきなり動かなくなってる。。。!
という辛みがあるので注意。