@User uploaded a file: Untitled

I guess it is more RX question, but still. I have this EventController, and when I add another observable to it, that throws exception, the composite observable stops working, because it is in the terminated state. Is it possible to throw exception and somehow continue to work further?

Thanks!

@borboss i think you want to swallow the exception in your flatMap code block. the only other RX option I know if is to retry() but that will go back to the start.

@ron my code handled that :)

yup it does and in a cleaner way too, been writing too much java lately

I'm thinking about doing a release tonight. Something else we should get into the release?

With or without the config?

I quickly scanned the code and I want to check something to night

@ron Probably with. I think we can close that issue tonight as well.

I'm working on it in a local branch.

@nimakro I don't think I will merge your PR, but I'll steal ideas from it if that's OK. You were the catalyst for sure, but I'd like to take a slightly different approach and still get all the benefits.

@edvin Hey that's perfectly fine..go a head...I am still learning and the whole point of the PR was to start the discussion so if you have a better/nicer/cleaner way than that's great.... looking forward to see your idea👍

@nimakro Great. Mine is not vastly different from yours 🙂

😉 👍

@carlw Carl, I see there are methods like onErrorResumeNext - can I just switch the flow to another observable in case of error?

@borboss is your exception checked?

@carlw yeah sure. if(it.size == 0 || enabled) { forFuncId(funcId.id) } else { Observable.error(Exception("Cannon disable. There are fighters with this profile")) }

@carlw Actually I just wanted to have a CompositeObservable for errors in the controller, in case if something goes not completely wrong, I can add observables to it

@carlw Well. I guess doOnError is what i need)

thanks!

will that continue your processing?

@carlw no ;-( actually it is like a subscription in a middle ;-(

didn’t work

@carlw Actually I don’t want to pass some kind of wrapper around object, that shows whether the operation was successfull or not. It seems to me that it is not very reactive.

@borboss you want to skip over an item that fails the action in flatMap() and continue with the rest of the stream?

without wrapping up an exception?

@User uploaded a file: Untitled

@carlw - well, I did the following. I just added the subscription and then pass the correct object to the gui CompositeObservable, and print the exception on exception

@carlw But, yes, I wanted to do what you said. So the CompositeObservable in gui won’t become terminated