rx-java

10熱

3答えて

同じ正確なアイテムが最後のxミリ秒以内に放出された場合にのみ発光が発生しないようにしたいと思います。私はスロットルとデバウンスのオペレータを見てきましたが、私がここで私を助けることができるかどうかはわかりません。私が使用できる別の演算子がありますか、何とかそれらを合成できますか？

0熱

1答えて

ObservableのonSuccess（）またはonError（）の後に実行するメソッドはありますか？

私はアプリでいくつかの読み込み動作を表示する必要があり、作業が完了したら - の結果が成功したかどうかにかかわらず、それを却下したい、またはエラーをしばしばします。したがって、私はそのようなコードで終わります： addDisposable(router.launchHomepage() .compose(loadingView.show())) .subscrib

2熱

1答えて

補強コールエンキュー方法又はRxjava

レトロフィットのCallエンキュー方法を表している：エラーが要求を作成する、サーバと話し発生した場合非同期要求を送信し、その応答またはのコールバックを通知します、または応答を処理する。とRxjava according to this tutorialです： RxJavaとRxAndroidライブラリは、私たちは簡単に、これらの2つが同じアプローチを持っているようだ官能性反応プログラミング

0熱

2答えて

複数のリクエストの最後のリクエストを取得する

アイテムを含むリサイクルビューがあります。私がアイテムをクリックすると、別のリサイクラビューでアタッチするためにいくつかのデータを取得するためのAPIコールが発生します。リサイクラのアイテムで複数回クリックすると、多くのAPIリクエストが返され、最後にクリックされた項目の要求と私は要求の残りをキャンセルし、私はtiは、タイマーを使用してみてくださいそれらを無視したいが、それはそこに私の現在のコード

2熱

2答えて

RxJavaの空リストのフィルタリングとfirstOrDefaultの使用

空であってもなくてもよいリストをフィルタリングしようとしています（またはリストにないアイテム）。 inboxDataは別のオブザーバブルで埋められます。 private BehaviorSubject<InboxResponse> inboxData = BehaviorSubject.create(); public Observable<Item> getInboxItem(String

1熱

1答えて

RxJava 2でサブスクライバを再生する方法は？

私はrxJava2の中で、いったんアクションが実行されると再び加入者に電話をかけることができる方法を探しています。私の意図を具体的に説明しましょう。私はネットワークにretrofit2を使用していますが、それは問題ではありません。この質問はrxJavaに関するものです。私はトークンをリフレッシュした後、APIコールを再試行したいと思います。私が設定する必要があるのは、私がapi呼び出しを行うたび

0熱

1答えて

RxJavaHooksは私のAndroidのユニットテストファイルで私のAndroidのユニットテスト

で解決することができない、私はこの輸入をしています：輸入rx.plugins.RxJavaHooksを。私はRxJavaHooksを使用する必要があります。私のGradleファイルで、私はRxJavaとRxAndroidの依存関係を追加しました：コンパイル "io.reactivex：rxandroid：$ RXANDROID_VERSION" コンパイル「io.reactivex：rxj

1熱

1答えて

PublishSubjectが最初の要素を発行しない理由

私はrxとPublishSubjectを使用しようとしています。 PublishSubject<MyEvent> events = PublishSubject.create(); をし、私のサービスに私はその中MyEventを置く：だから私は、オブジェクトを作成します。 events.onNext(new MyEvent); ので、時々私は、最初のイベントが、私が受け取る秒を受信しません。そし

0熱

1答えて

RXJavaは以前のflatMapの戻り値を保持します

RX JAVA（java8）では、以前のflatMapまたはmapの値をどのように保持できますか？ public void createAccount(]) { JsonObject payload = routingContext.getBodyAsJson(); socialService.getOAuthToken(payload) .flatMap(tok