問題タブ [rx-java2]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - Retrofit2 + RxJava2 + RxAndroid エラー
Subscriber
クレートしてサブスクライブしようとすると、以下のようなエラー メッセージが表示されます。
build.gradle
GooglePlaceService.java
ApiUtils.java
観測可能なObservable<GooglePlacesResponse>
ものは以下のとおりです。
android - RxJava (Android) - スケジューラを有効にしておくことに害はありますか?
データベース オブジェクトへの参照を保持するシングルトンがあります。私がやりたいことは、データベース操作を単一の IO スレッドに制限することです。
まず、次のことを試しました。
このアプローチの問題は、Schedulers.io() が、上記のオブザーバブルをサブスクライブするサブスクライバーごとにプールから異なるスレッドを提供する可能性があることです (それは望ましくありません。コードを同じスレッドで実行したいのです)。常に)。
次に、スケジューラを自分で保持するアプローチに移りました。
私はRxJavaを初めて使用するので(そして、多くの落とし穴があるようです)、質問します.Schedulerオブジェクトを存続させておくことに害はありますか(SQLSingletonはシングルトンであるため、Schedulerもそうなることに注意してください)?
rx-java - Rxjava 2 でのネットワーク エラーの処理 - Retrofit 2
Rxjava2 でさまざまなネットワーク エラーを処理するにはどうすればよいですか?
RxJava 1 では、スロー可能なエラーのインスタンスが IOException または HttpException であるかどうかをチェックしていましたが、RxJava 2 では、スロー可能なエラーのタイプはGaiExceptionです。
コードスニペット
参考:https ://github.com/square/retrofit/issues/690 https://android.googlesource.com/platform/libcore/+/5d930ca/luni/src/main/java/android/system/GaiException.java
rx-java - オブザーバー用使い捨て
RxJava 1 では、オブザーバーを使用してサブスクライブすると、サブスクライブを解除できるサブスクリプションが返されました。
RxJava 2 では、Observer でサブスクライブすると void が返され、Disposeable は返されません。その「サブスクリプション」を停止するにはどうすればよいですか?
編集Disposable
: のように、それ自体が実装されていBehaviorSubject
ないオブザーバーを使用する場合の処理方法 この例のように:
rx-java - flatMapCompletable は指定されたアクションを呼び出しません
Completable が正常に完了すると、flatMapCompletable が指定された Action を呼び出すことを期待していました。しかし、思ったようにうまくいきません。簡単な例を次に示します。
これは予想される動作ですか?その場合、Completable タスクが終了したかどうかを確認するにはどうすればよいですか? Completable.complete().doFinally()
?
android - コードを RxJava2 コードに変換する
私は RxJava 2 とその操作方法を理解しようとしています。また、コードを RxJava コードに変換して RxJava を理解しようとしています。しかし、私はまだそれを理解できないようです。誰かがそれを再コーディングする方法をさらに説明してくれれば、本当に助かります。
これは、RxJava でコーディングしようとしているコードです。
getMyUsers() メソッドを Observable にしようとしていました。しかし、私はまだこの問題にどのようにアプローチするかについて混乱しています。誰かが私を正しい方向に向けてくれれば、本当に感謝しています。:)