問題タブ [rx-java2]

Subscriberクレートしてサブスクライブしようとすると、以下のようなエラー メッセージが表示されます。

build.gradle

GooglePlaceService.java

ApiUtils.java

観測可能なObservable<GooglePlacesResponse>ものは以下のとおりです。

データベース オブジェクトへの参照を保持するシングルトンがあります。私がやりたいことは、データベース操作を単一の IO スレッドに制限することです。

まず、次のことを試しました。

このアプローチの問題は、Schedulers.io() が、上記のオブザーバブルをサブスクライブするサブスクライバーごとにプールから異なるスレッドを提供する可能性があることです (それは望ましくありません。コードを同じスレッドで実行したいのです)。常に）。

次に、スケジューラを自分で保持するアプローチに移りました。

私はRxJavaを初めて使用するので（そして、多くの落とし穴があるようです）、質問します.Schedulerオブジェクトを存続させておくことに害はありますか（SQLSingletonはシングルトンであるため、Schedulerもそうなることに注意してください）？

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

RxJava 1 では、オブザーバーを使用してサブスクライブすると、サブスクライブを解除できるサブスクリプションが返されました。

RxJava 2 では、Observer でサブスクライブすると void が返され、Disposeable は返されません。その「サブスクリプション」を停止するにはどうすればよいですか?

編集Disposable: のように、それ自体が実装されていBehaviorSubjectないオブザーバーを使用する場合の処理​​方法 この例のように:

Completable が正常に完了すると、flatMapCompletable が指定された Action を呼び出すことを期待していました。しかし、思ったようにうまくいきません。簡単な例を次に示します。

これは予想される動作ですか？その場合、Completable タスクが終了したかどうかを確認するにはどうすればよいですか? Completable.complete().doFinally()?

私は RxJava 2 とその操作方法を理解しようとしています。また、コードを RxJava コードに変換して RxJava を理解しようとしています。しかし、私はまだそれを理解できないようです。誰かがそれを再コーディングする方法をさらに説明してくれれば、本当に助かります。

これは、RxJava でコーディングしようとしているコードです。

getMyUsers() メソッドを Observable にしようとしていました。しかし、私はまだこの問題にどのようにアプローチするかについて混乱しています。誰かが私を正しい方向に向けてくれれば、本当に感謝しています。:)