1
私はthis articleでの使用RxJavaの素敵な例を見つけた:、Retrofitはrx.Future/Task/Async/Singleをサポートしていますか?
Subscription subscription = Single.create(new Single.OnSubscribe() {
@Override
public void call(SingleSubscriber singleSubscriber) {
String value = longRunningOperation();
singleSubscriber.onSuccess(value);
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1() {
@Override
public void call(String value) {
// onSuccess
Snackbar.make(rootView, value, Snackbar.LENGTH_LONG).show();
}
}, new Action1() {
@Override
public void call(Throwable throwable) {
// handle onError
}
});
をしかし、私はレトロフィットを使用しておりますので、私はRetrofitServiceを作成し、1つのデータセットにバックエンドへの2つの要求の結果を結合する単一のクラスを使用したいです
シングルに登録すると、onSuccessアクションと onErrorアクションのみが存在します。単一のクラスを観測するために、単一の変換 のメカニズムを可能にするいくつかの演算子と、観測 より演算子の異なるセットを有しています。例えば、 Single.mergeWith()演算子を使用して、同じタイプの2枚の以上のシングルは 観測一つに 各単一の結果を発する、観測を作成するために一緒にマージすることができます。
それは、この(とどのように)を達成することは可能ですか?