android - Retrofit を使用して RxJava で結果を管理する方法

Question

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

Answer 1

最近、RxJava の使用例をいくつか公開しました ( https://github.com/dawidgdanski/rx-java-handies )。ケースの API を調査する際に役立つと思われる場合は、喜んでお手伝いさせていただきます。