rx-java2

1熱

1答えて

takeUntilは、Retrofit、RxJava、Gsonで最適化されたキャッシュとネットワークメソッド

RxJavaのtakeUntil演算子を使用して最適化されたキャッシュとネットワークメソッドを実装しようとしています。私はGsonモデルを使用して、APIからのJSON応答を解析しています。 Gsonモデルを使用しているため、サーバーからデータを取得できません。戻り値の型はNetwrok RequestとDisk cacheの両方で一致しません。私はいくつかの方法を試してきましたが、それを正しく

0熱

1答えて

RX-Javaの郵便番号が失敗した理由

ここでは、テストコード final Flowable<Integer> f1 = Flowable.fromPublisher(s -> { s.onNext(Integer.valueOf(1)); s.onComplete(); }); final Flowable<Integer> f2 = Flowable.fromPublisher(s -

0熱

1答えて

RxJava 2：件名の置換<T,R>

RxJava 1.xでは、SubjectでT -> Rの変換を行うことができました。たとえば、入力タイプはInteger、出力タイプはStringです。 RxJava 2.0ではこのオプションは削除されましたが、Subject<T,R>の代わりにSubject<T>に変更されました。この変更はRxJava wikiのWhat's different in 2.0文書にも記載されていますが、残念なが

0熱

2答えて

RxJava2を使用した購読者の再クエリーと更新

私は、レトロフィットサービスを利用しているアプリケーションにデータレイヤーを持っています。（これまでのところ、ネットワーク上でのみ永続性があります。さらに開発を進めると、オフラインで最初にローカルストレージを追加します） Retrofitはサーバに電話をかけたときにObservable<List<Item>>を返します。これはうまくいく。私の購読者では、購読するとリストを受け取り、Itemsで自

1熱

2答えて

RxJava2：JUnitの環境で実行しているときのテスト

にスローされる例外は以下のコードがクラッシュしないでしょう。しかし、それはアプリで実行中にクラッシュします。コンソールにエラーログが表示されますが、テストは合格とマークされます。 @Test public void test() { Observable observable = Observable.error(new RuntimeException()); ob

0熱

1答えて

継続的に放射するRxJava Observableの作成方法は？

RxJava BlockingObservableを作成しようとしていますが、（条件== true）またはタイムアウトが発生するまで、Xミリ秒ごとに変数の値を出力します。以下のコードは私が望むものに近いようですが、常にONCEを出して終了します。奇妙なのは、私がtakeUntil()の状態になっていることです。これは決して真実ではありません。この観測可能なものが継続的に放出され、最終的にはタイム

1熱

4答えて

Retrofit2 + RxJava2 + RxAndroidエラー

Subscriberを登録して購読しようとすると、以下のようなエラーメッセージが表示されます。 can not resolve method 'subscribe(anonymous rx.Subscriber<GooglePlacesResponse>)' build.gradle // JSON Parsing compile 'com.google.code.gson:gson:2.6

1熱

1答えて

RxJava（Android） - スケジューラを稼働させておくことに何らかの害がありますか？

私は自分のデータベースオブジェクトへの参照を保持するシングルトンを持っています。私がしたいのは、単一のIOスレッドに対するデータベース操作を制約することです。は、最初に私が試した次 class SQLSingleton{ ... public Observable<MyObject> query(final String id){ return Observable.from

5熱

1答えて

Rxjavaでのネットワークエラーの処理2 - Retrofit 2

Rxjava2でさまざまなネットワークエラーを処理するにはどうすればよいですか？ Rxjava 1ではIOExceptionまたはHttpExceptionが戻ってきたが、RxJava 2ではthrowableエラーの型がGaiExceptionになっています。コードスニペット RestAPI restAPI = RetrofitHelper.createRetrofitWithGson().c