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

Question

我有一个用 RxJava 调用的 Retrofit 请求 API。一切正常。

我该如何优化这段代码。我是 RxJava 的新手。如果能提供一个小示例代码或 link，我将不胜感激。谢谢

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();
            }
        }
    });

Answer 1

有几个选项：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); });

Answer 2

最近我发布了一些 RxJava 用法示例 (https://github.com/dawidgdanski/rx-java-handies)。如果您在调查 API 案件时发现它有用，我很乐意为您提供帮助。

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

How to manage results in RxJava with Retrofit

android

rx-java

retrofit2