I have ServiceB which relies on the response of service A, ServiceB gets triggered but now I hit the error of NetworkOnMainThreadException @ onError. I'm new to RxJava and just starting to try out on examples. Please help, thanks.
ServiceA
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.flatMap(new Function<ResponseA, Observable<ResponseB>>() {
@Override
public Observable<Execution> apply(ResponseA responseA) throws Exception {
return ServiceB(responseA.some_id); #ServiceB gets triggered here
}
})
.subscribe(new Observer<ResponseB>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable t) {
#NetworkOnMainThreadException!
}
@Override
public void onNext(ResponseB responseB) {
}
});