RuntimeExceptionmay be thrown (
NullPointerException, etc.). The behavior I'm seeing is that if a
RuntimeExceptionis thrown in the subscriber
onErrorcallback is firing, but the
doOnTerminateactions are not.
.map(mapped -> combine(data, mapped))etc.
mapand use a empty
.subscribe()after the flatmap. Might be appropriate to use
doOnEach. Perhaps only part of your logic needs to be there. Not my favorite solution but at least it's readable.
doOnTerminateis called after a downstream error is at the discretion of the operator