1

我有一个使用 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();
            }
        }
    });
4

2 回答 2

3

有几个选项: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); });
于 2016-01-13T16:29:57.490 回答
0

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

于 2016-01-13T21:35:23.463 回答