ここに問題があります。私は結果がさらに処理される単一のものに集約されるいくつかの非同期操作を持っています。ただし、すべての操作が等しいわけではなく、エラー処理は、どの操作が失敗するかに基づいて異なります。優先度の高いRxJavaジップ
A、B、Cの操作があるとしましょう.Aが失敗した場合は処理を終了する必要がありますが、BまたはCが失敗した場合は他の処理を引き続き正常に処理します。
現在のところ、カウントダウンラッチと数百のコード行に近い多くの状態管理を使用してこれを実現しています。私はこれをRxJavaベースの実装に移したいと思います。私の最初の考えはObservable.zip
演算子を試していましたが、それはすべての観測値を等しく扱います。この場合はそうではありません。私の他のアイデアは、通話を連鎖させることでしたが、それはすべての操作が同時に開始されず、全体的な時間が長くなることを意味します。
これを達成する方法を教えてくれる人は誰ですか?
簡潔に、確かに。リファクタのコミットメッセージは、「140行のコードを38に変更する方法」です。 –