android - 如何使用Retrofit在RxJava中管理结果

我使用RxJava进行了Retrofit请求API调用。一切正常。

我如何优化此代码。我是RxJava的新手。
我将感谢一个小的示例代码或链接。
谢谢。

Observable<Review> observer = Observable.just(review);
    observer.subscribeOn(Schedulers.newThread())
            .observeOn(Schedulers.newThread())
            .map(new Func1<Review, Uri>() {

                @Override
                public Uri call(Review review) {
                    Uri uri = null;
                    /// Some code
                    return uri;
                }
            }).subscribe(new Action1<Uri>() {
        @Override
        public void call(Uri uri) {
            if(uri != null) {
                Api.Reviews reviewApi = retrofit.create(Api.Reviews.class);
                Observable<BaseResponse<Review>> reviews = reviewApi.createReview(authToken, review);
                reviews.subscribeOn(Schedulers.newThread())
                        .observeOn(AndroidSchedulers.mainThread())
                        .map(new Func1<BaseResponse<Review>, Void>(){
                            @Override
                            public Void call(BaseResponse<Review> response) {
                               //Code Here
                                return null;
                            }
                        }).subscribe();
            }
        }
    });

最佳答案

有几个选项：map，doOnNext，flatMap等，具体取决于您随后要对改造结果执行的操作。例如：

reviews
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.io())
.map(r -> {
    try {
        someDB.save(r);
    } catch (Exception ex) {
        throw new RuntimeException(ex);
    }
    return r;
})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(v -> { }, e -> { log(e); });

要么

reviews
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.io())
.doOnNext(r -> {
    try {
        someDB.save(r);
    } catch (Exception ex) {
        throw new RuntimeException(ex);
    }
})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(v -> { }, e -> { log(e); });

要么

reviews
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.io())
.flatMap(r -> {
    try {
        someDB.save(r);
        return Observable.empty(); // or Observable.just(r);
    } catch (Exception ex) {
        return Observable.error(ex);
    }
})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(v -> { }, e -> { log(e); });

关于android - 如何使用Retrofit在RxJava中管理结果，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/34765240/