rx-java

0熱

1答えて

Observableのすべてのイベントを1つのスレッドで処理する方法はありますが、Rxjavaの別のスレッドで最新の値を取得する方法はありますか？

私はAndroidでRxJava2を使用していますが、私は以下の問題がありますが、Androidに固有の問題ではありません。私は全てのイベントをプッシュするためにPublishSubjectを持っています。異なるイベントに基づいて私のコードの複数の部分でpublishSubject.onNext()と呼んでいます。しかし、私はこれらのイベントを購読する私のコードの中心的な場所を持っています。以下

0熱

2答えて

RxJava + Android + GreenDao：複数のエンティティをカスケードで削除する

データベース、コース、講義の2つのテーブルがあります。それらは1：Nの関係です。私の問題は、複数のコースを削除したいということです。その前に、関連する講義がすべて削除されていることと、講義とともにいくつかのファイルが削除されていることを確認する必要があります。それは私が複数のコースを削除したい、である、すべてのコースには、次の手順を実行する必要があります。削除講義ファイルとレコードがコースを削

0熱

1答えて

Schedulers.io（）をオーバーライドする方法は？

非常に遅いデバイスでアプリの動作をエミュレートする必要があります。だから私はSchedulers.io（）優先度の低い1つだけのスレッドを使用するをオーバーライドします。可能であれば、タスクをキューに入れる前にいくつかの遅延を追加する。コードでSchedules.io（）を変更せずに、一度グローバルに行う方法はありますか？

1熱

2答えて

Rxjava tolist（）が完了しません

RxJavaコールチェーンに問題があります。 toListが正しく動作していません。私はtoList（）が完了するために何か必要があると思います。そういうわけでそれは止まっている。しかし、私は mModel.getLocations() .flatMapIterable(new Function<List<Location>, List<Location>>(){

2熱

1答えて

RxJava tricky startWith（Observable）

次のコードは、observable2が完了した後でobservable1からアイテムを放出します。私は別の動作を達成するために必要 observable1.startWith(observable2) .subscribe() observable1 -> 0 1 2 3 observable2 -> 1 2 3 4 5 6 observable1.startWithD

1熱

1答えて

java.lang.NoClassDefFoundErrorが：io.reactivex.Flowable

私はAndroid Studio 3.0 Canary 6を使用してRxJava Version 2.0.1.を使用しています。私はこの private void subscribeToObservable(Observable<List<CalendarDto>> observable) { DisposableObserver<List<CalendarDto>> d = getD

0熱

1答えて

RxAndroid、Observableが放出を完了したかどうかを検出する方法

firebaseデータベースから保存された食品のリストを取得するために次のコードスニペットを作成し、そのリストを使用すると、firebaseデータベースから個々の食品の詳細を再度取得します。次のコードはうまく動作しますが、第2フラットマップに最初のフラットマップの発光が完了したことを知る方法がわかりません（すべてのフードリストが処理されました）。だから私はonCompleted()メソッドを呼び

3熱

1答えて

RxJava - スキャンとフラットマップを組み合わせる方法はありますか？

私はStringとlongを受け取り、Single<String>を返す関数を持っているとしましょう。 Single<String> stringAddition(String someString, long value) { return Single.just(someString + Long.toString(value)); } 今、私はこれを行う方法の損失でよ、このO

1熱

1答えて

RxJava just（）計算スレッド

私は混乱しています。私はいくつかの長年の仕事（約5秒）を行い、結果としてStringを返す方法を持っています。私はすべてが正常に動作しますObservable.just()Observable.fromCallable()に変更した後、私のdoJob()方法はmainThread に計算 private Observable<String> getJobObservable() { re