rx-java

0熱

2答えて

rxjavaでコーディングした後、全く違った方法で考えることができます。コレクションにデータを保存する操作が必要なときはどうすればよいのですか？私は、すべてのリクエストが完了した後、後で取り組むことができます。例えば、私はいくつかのAPIにいくつかのput呼び出しを送信し、後でいくつかの "間違い訂正"を行うためにマップ内のすべての失敗した呼び出し応答を保存したいと言うことができます。これまで

0熱

2答えて

RxJava/RxScalaでobservableをキャッシュする方法

私は、RxScalaに基づいて反応性スカラドライバを使用してmongodbを呼び出すREST APIを持っています。私のAPIコントローラまたはサービス層で、私はhazelcast（またはその他のキャッシュツール）を使用して、MongoDBのために呼び出しを避けるために、キャッシュを使用する必要がすべての私のサービスは非同期であり、唯一、観察を返し、どのように私ができる任意のアイデア観察可能な

-1熱

1答えて

レトロフィット+ RxJavaは、私は、クエリに必要となるAPIを使用しています異なるリンク

でリトライ特定の国のリリース年だけですので、私は+/- 1年間のリクエストを再試行する必要があります。言い換えれば、最初のattempが失敗した場合、別のリンク/クエリで再試行したい。 RetrofitとRxJavaを使用してこれを実現するにはどうすればよいですか？

2熱

2答えて

RxJava：タイムスタンプが期限切れになるまでキャッシュから読み取る

私は次のようなシナリオを持っています：Fooというオブジェクトがあります。このFooオブジェクトはリモートサービスから来ており、このインスタンスをローカルにキャッシュしたいと思います。一定の時間が経過するまで使用してください。これまでのところ、私が来ている今 public class FooState { private Foo foo; private long times

0熱

2答えて

RxJavaデバウンスメソッドコールが受信されました

メソッドコールのための簡単なスロットルを実行したいと思います。私はdoSomething(number)のためのコール受信した数とdebounceに基づき、観察を作成したい、 public void called(int number){ doSomething(number); } が、この方法はあまりにも頻繁に呼び出されます。私はこの方法を持っています。これは可能ですか？

1熱

1答えて

配列リスト内のすべての観測可能な文字列を収集

私はキーと値のペアを含むmapを持っています。このmapから、結果として返されるデータベースにストリーミングして格納します。Observable<String> 私の問題は、ブロックしないでこの文字列に到達しようとしたときに発生します。常に空です。ここでは私の実装です： public Observable<List<String>> uploadKeys(Map<String, String>

0熱

1答えて

ユニットテストRxJavaオブザーバブル

RxJavaを初めて使用しています。私はrestTemplateを使って残りのAPIを呼び出すObservableを書いています。私はサービスクラスで作成したObservablesを単体テストしたい。私はMockMVCを使って残りのAPIコントローラとサービスクラスをユニットテストしていることに気付いています。だから、MockitoやMockMVC、あるいは利用可能なフレームワークを使用して、サ

-1熱

1答えて

rxjavaを使用して複数のAPIエンドポイントを1つのストリームでポーリングする

現在複数のエンドポイント（異なる）をポーリングしようとしています問題は私が集計した状態を返さなかったエンドポイントやり方は流れが基本的にあるので：リクエストを構築する - > 1つのストリームにマージ - >投票を応答するために - >チェックは状況が一致している：待って流れをやり直していない場合ストリームからオブザーバーを取り出す場合これは私が書かれていると私はおかげでたくさんの何か

2熱

3答えて

RxJava - 別のストリームに基づいて購読を解除する

私はこのシナリオを持っています：非常に素早く項目を生成するストリーム UIスレッドで多くの作業を行うサブスクライバ。特定の条件が満たされた場合、余分な仕事を保存するために退会したいと思います。私はまた、再契約の際に余分な仕事をしたいと思います。例：ネットワークイベントはアイテムへの更新を生成し、モデルはそのアイテムを更新してアイテムを更新し、更新されたアイテムで新しい監視オブジェクトを公開