問題タブ [rx-java2]

MVP でコーディングされた Android アプリの例を見ていました (リンクはこちら)。しかし今、チュートリアルで指定された RxJava1 コードを RxJava2 コードに再コーディングしたいと考えています。しかし、私は特にそれで苦労していunSubscribe()ますisUnSubscribed(). 私はそれを変換しようとしましたが、私の試みを共有します。

RxJava1 コード:

これはRxJava2コードに対する私の試みです:

私はRxJavaの概念にかなり慣れていません。誰かが私の過ちを指摘し、私を導くことができれば、それは素晴らしいことです. :)

Singles、Maybes、および Completables をマルチキャストするための推奨される方法は何ですか? それらを標準の Observables に変換してマルチキャストすることをお勧めしますか?

ConnectableSingle、ConnectableMaybe、およびがないことに少し驚いていConnectableCompletableます。この背後にある理由は何ですか？開発に努力するだけの価値はありませんか？

私のアプリケーションには、サーバーから 2 つの zip ファイルをダウンロードするユースケースがあります。そのために、レトロフィット + rxjava (2 つの別々のレトロフィット サービスを作成) を使用しています。並行して実行するために、新しいスレッドでレトロフィット サービスをサブスクライブし、後で zip オペレーターを使用してそれを結合しました。それはうまくいっています。しかし、後で解凍操作のためにマップ演算子を両方のサービスに追加しましたが、マップ演算子に記述されたコードを実行せず、制御は直接 zip 操作に渡されます。私はこれに取り組む方法がわかりません。私は反応的な世界の初心者です。

今まで試したこと

および getObserver() 関数

コードが実行されると、コントロールは zip オペレーターの apply() 関数に転送され、両方のオブザーバブルのマップ オペレーターは実行されません。

そして別の質問があります

2 つのオブザーバブルをマージ/圧縮しており、オペレーターに渡されるタイプは Response<"ResponseBody">です。実際には、そこにダウンロードされたファイルパス(文字列型)が必要です。そのためにはどうすればよいですか?

**

@Yaroslav Stavnichiy の説明に従ってソリューションを更新し、現在は機能しています

**