問題タブ [rx-java2]

RxJava 2& Retrofit 2( https://github.com/JakeWharton/retrofit2-rxjava2-adapter )を使用しており、無応答 (204) タイプをどのように処理するのか疑問に思っていました。rxjava1 で使用してObservable<Void>いましたが、rxjava2 では許可されなくなりました ( https://github.com/ReactiveX/RxJava/wiki/What's-different-in-2.0 -> Nulls )

現在、カスタム タイプ (NoContent と呼びます) での Json 解析をバイパスするためにハッキングしましたが、もっと良い方法があるかどうか疑問に思っていました。

編集：

toList 演算子の実行後、元の Flowable<<\List>> は Single<<\List>> に変換されます。コンシューマーを作成してシングルにサブスクライブすると、オブジェクト以外のコンシューマーの値の型を変更できないことがわかりましたか?

複数の HTTP 呼び出しを圧縮して並行して実行します。現在、そのうちの 0..n は明らかに失敗する可能性があります。問題は、たとえば 2 つの呼び出しがほぼ正確な時間に失敗した場合、エラー 1 が処理されますdoOnErrorがonErrorReturnItem、エラー 2 がすり抜けて例外が発生することです。これは、2 つの onError 演算子でエラー 1 がまだ完全に処理されていないときに、エラー 2 が発生した場合に発生すると思います。

次の簡略化されたコードで再現できます。

したがって、時々これはスローされます：

1 つのエラーSingle.zipのみを許可するべきではありませんか? これを行うより良い方法はありますか？

RxJava2 を使用して、ユーザー名とパスワードが十分に長い場合にログイン ボタンを有効にしたいのですが、エラーが発生します。

これが表示される両方のセクションで、次map(inputTextのエラーが表示されます。

そして、エラーa && bは

他にもエラーがありますが、最初の 2 つのエラーが根本的な原因だと思いますが、Observable.combineLatest今の代わりに何を使用すべきかわかりません。

私はRxJava2を介して戦っています。私の解決策が受け入れられるかどうか、またはそれを改善する方法があるかどうか疑問に思っています。

使用事例

1. ユーザーがデータ更新ボタンを押す
2. ダイアログが表示されます - お待ちください
3. 複数のバックエンド呼び出しが並行して処理されます
4. これらのいずれかが終了するとすぐに、データはローカル データベースに保存されます
5. すべてのリクエストが終了したら (バックエンド コールと永続化)、ダイアログを閉じる必要があります。

現在のソリューション

私はCompletablesこのように見えるいくつかを持っています:

リストに追加し、merge演算子を使用して、それらを 1 つにパックします。

可能な改善

わかりましたので、これは意図したとおりに機能します。しかし、あまり嬉しくないものがあります。

subscribeOn(Schedulers.io())各 Completableに を本当に追加する必要がありますか? それなしでは並行して動作しませんが、これを行うためのより良い方法があるでしょうか?

すべての補完可能なものにはこれらの行があります。

それを1つのメソッドに抽出する方法はありますか? 私はこのようなことを試しました：

Observable と DAO を入れるだけです。もちろん、それはコンパイルされません。ジェネリックについては、私がすでに持っているよりもはるかに多くの知識が必要なようです。

長い質問で申し訳ありません。ユースケース全体を短い言葉で説明するのは難しいです。

処理が遅くなる可能性のある画像を処理するクラスがあります。作業が完了すると、ドミナント カラーなど、画像に関するいくつかの機能がクラスに含まれます。

ドミナントカラーを知りたいコードは他にもたくさんありますが、要求されたときに、準備ができている場合とそうでない場合があります。

RxJava2 を使用してこれを実装する簡単な方法をまだ見つけていません。誰かが私を助けることができますか？

要約すると、次のメソッドを作成できればいいのですが。

1. 複数のサブスクライバーが通話/サブスクライブできるようにします。
2. 処理が完了すると、サブスクライバーは結果を受け取ります。
3. サブスクライバは、メモリ リークを避けるために、自動的に添字が解除されます。2 回目のイベントはありません。また、引き続き購読する理由はありません。
4. 後でメソッドをサブスクライブ/呼び出すサブスクライバーは、キャッシュされた値を取得するだけです。

ReplaySubject には探しているプロパティがいくつかあるようですが、正しく実装する方法がわかりません。

RxJavaバージョン2でObservableをPublisherに変換するには?

最初のバージョンには、まさに必要なことを行うhttps://github.com/ReactiveX/RxJavaReactiveStreamsプロジェクトがあります。しかし、どうすればRxJava 2でそれを行うことができますか?

私もそれらのクラスを持っているとしましょう

目標: すべてのイベントを施設名とともに出力します。

制約: RxJava2、ファシリティは 1 つずつしかロードできません ( getFacility(facilityId))

から、Observable<Event>施設をロードしてそれぞれのイベントに戻す方法がわかりません。

基本的に私は次のようなことを考えていました：

その後、私は盲目になり、それらをイベントにリンクする方法を見つけることができません. を使用することも考えましzipたが、それが解決策になる可能性がありますが、後で施設を設定するためのイベント参照を保持する方法が見つかりませんでした。

反応的な方法は何ですか？どんなヒントでも大歓迎です。

特定の条件でRxJava Function .filter() を使用する方法、 ID が 168 のデータのみが必要です。これは正しい方法であるか、コードスタイルを変更する必要があります。貴重な提案をしてください。(RetroLambda を使用しない場合:))

私は次のような応答があります

私はこの方法を試してみましたが、（次に）注目しています