Replacing a chain of calls using rx Observable

[Rajdeep Biswas]

Hi,

I have a code that uses rx AsyncResponse as output and has below inside the method:

Observable.just(context)
.flatMap(this::doSomething)
.flatMap(this:doSomethingElse)
.flatMap(this::anotherProcessing)
.subscribe(onNext-> {}, onError-> {});
...etc

The thing is that the sequence of calls actually does not needs async but the way of handling errors seems like a good style to me. Without actually needing async model to rewrite this method, the simple idea will be to make the method calls and put all of it inside a try-catch block. But is there a better way to write such code? I'm using JDK 8.

Thanks
Rajdeep

[Stephan van Hulst]

I'm a bit confused. What problem is your application experiencing that you're trying to solve?