rx-android

0熱

1答えて

Androidデバイスがロックされていると、RxJavaの間隔とタイムアウトが時折停止する

私のアプリケーションの機能の1つは、ユーザーが誤って有効にしたままにならないように、5分後にタイムアウトするように設計されています。アクティビティには、Observable.interval()で更新されたカウントダウンタイマーが表示され、機能のタイムアウトはObservable.timeout()によって実装されます。時々カウントダウンが実行され、ユーザーがデバイスをロックすると、は発光

1熱

2答えて

リアクティブプログラミングを使用したAndroidフォームの検証

私はRxJava、RxAndroidをかなり使い慣れています。私は2つのeditTextパスワード用とパスワード確認用の2つがあります。基本的には、2つの文字列が一致するかどうかを確認する必要があります。これはObservablesを使用して可能ですか？私はそれをつかむことができるので、例を本当に感謝します。乾杯。

0熱

1答えて

RxJava2のPublishProcessor

私はPublishProcessorという値を連続的に出力しています。そして私はPublishProcessorを2つの異なるスレッドで観察する2人の加入者で購読しました。第1の加入者が継続的にonNext(T)でデータを受信しながら、第2の加入者はonNext(T)以下にいくつかの呼び出しを受けた後、エラーError: Could not emit value due to lack of r

2熱

2答えて

RXjavaのトランスフォームのタイプ

シングルからシングルへのようなオブザーバブルを変換することは可能ですか？オペレータcompose（）がこの目的のために使用されていると思いますが、実装方法が分かりません。私がここで達成したいことは、次のコードスニペットでより明確に理解できます。 @Override public Single<SystemDefaults> getSystemDefaults() { SystemD

10熱

3答えて

同じ発光がミリ秒前に発生した場合の発光の防止

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

2熱

1答えて

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

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

0熱

2答えて

RxJava | RxAndroidは1つずつアイテムを読み込みます

カテゴリ（A、B、C）のリストがあり、各リストにはサブカテゴリ（A1、A2）、（B1、B2）、（C1、C2）、および各サブカテゴリには、ダウンロードするアイテムのリスト（item_a11、item_a12）、（item_a21、item_a22）、（item_b11、item_b12）などがあります。ですから、次の順番でアイテムをロードする必要があります： Loading category A

0熱

1答えて

RxJavaストリームの途中で非同期操作を条件付きで追加するにはどうすればよいですか？ここ

は、私がasyncOperation()への呼び出しに絞ると、火災にそのコールバックのストリーム待ちの残りの部分を作るにはどうすればよい makeServerCall() .doOnNext { doStuff(it) } //TODO: if it == 0, call asyncOperation() and wait for

0熱

1答えて

rx Schedulerをメソッドパラメータとして取得せずに保持する方法はありますか？

私はこのような何かをした場合： Observable.just(1) .flatMap( //inner chain Observable.just(2) .subscribeOn(Schedulers.newThread()) ) .map(// we are in the inner chain thread! //) .subscribeOn(Sched