如何在RxJava中通过改装来管理结果

Question

我有一个使用RxJava的改装请求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();
            }
        }
    });

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案例时发现它很有用，我很乐意帮助您。