rx-java

0熱

1答えて

N個のネットワークコールを行う必要があるユースケースがあり、それらを実行した順番でデータを受け取りたい。それを行う最善の方法は何ですか？私は連結演算子を使用しようとしましたが、それは順次であり、マージ演算子では結果の順序が未定義であるため非効率です。

0熱

3答えて

RxJava Debounce onNext（）

SwitchCompatのクリック/スワイプをデバウンスしようとしていますが、成功しません。 onNextはdebounce（）を経由していませんが、以下のコードはうまく見えます：ユーザーがスイッチをスパムすると、onNextはデバッグのために省略されず、クリックごとに呼び出されます。これはRxJavaのバグでしょうか？ timer = Observable.create { subscribe

3熱

1答えて

RxJava2でコンシューマを並列実行する方法は？

RxJava2に関する質問があります。私は、Listの結果を並列に実行するために、固定スレッドプールの別のスレッドでコンシューマを実行したいと考えています。ここに私のコードは次のとおりです。 List<String> letters = Lists.newArrayList("a","b","c","d","e","f","g"); ExecutorService fixedThread

0熱

2答えて

バッファ（bufferClosingSelector）が自動的に終了している間にobservableが作成されます

私の質問は、各バッファの先頭で、バッファがいつ閉じるかを決定するobservableを返す関数を呼び出しているrxjavaバッファ（bufferClosingSelector）に関するものです。私の質問は、バッファが閉じたときに観測可能なものが自動的に終了するか、それとも自分自身を保証する必要があるということですか？

0熱

1答えて

RxJava2 Blocking Observable Timeout：タイムアウトが発生した場合、どのように結果を出すのですか？

JSON文字列の形式でイベントを発行するObservableがあります。私はそれを購読してブロックし、最初の文字列を取得したい。問題ない。しかしタイムアウトが発生すると、タイムアウトが発生し、缶詰のJSON文字列が放出されます。ここでは私の既存のコードです：あなたのサンプルコードsubscribeで必要とされないことを rxEvents .timeout(1, TimeUnit.SE

7熱

2答えて

流動性を規定する理由私はONATTACH（で同じフラグメントに加入してフェッチ添加DB

@Query("SELECT * FROM userdata") Flowable<List<UserData>> allUserDatas(); @Insert(onConflict = OnConflictStrategy.REPLACE) List<Long> insert(List<UserData> datas); userDao.allUserDatas() take(

-1熱

1答えて

rxjavaで境界線が開いていて、clossingしているバッファ

rxjavaで境界線が開いていて、clossingしているバッファで作業しようとしていますが、うまく動作しません。 0,1,2,3,0,1,3,0,3私は{0,1,2,3}、{0,1}で終わりたいと思っています。、3}、{0,3}である。これは私がこれまでしているコードです： PublishSubject openning = PublishSubject.create(); op

-2熱

1答えて

rxjava ...このプログラムがなぜ印刷されないのか分かりません

このプログラムがなぜ印刷されないのか分かりません。私は1秒ごとに文字列オブジェクトを印刷したい。だから私は間隔を使用します。このプログラムは名目上コンパイルされます。結果は印刷されません。なぜ？？？？？？？？？？（私は韓国人だ。だから、英語が未熟である。申し訳ありません...）.....ヘルプ public class main { public static void main

0熱

2答えて

KotlinでRXJavaマップを使用していますか？

これはミスタイプについて不平を言っているのはなぜですか？ map別に観察できるの値をtransforすることになったが、マップ override fun fetchExercises(): Observable<List<Exercise>> { return FirebaseDatabase.getInstance() .getReference("exercises")