rx-java

0熱

1答えて

データベース（NoSQLデータベースを使用）をすべてループし、すべての文書を「x時間」複製する必要があるスクリプトを実行しようとしています。私は、データベースには多くの文書が含まれている可能性があり、必要なだけ多くの文書を複製できるため、OOMが発生する可能性があります。私はそれを避けようとしましたが、それはまだ起こっています。誰かが私にこれを手伝ってもらえますか？ここに私のコードは次のとおりです

1熱

1答えて

RxViewがクリックしてonError

クリックを処理するためにRxViewを使用すると、onErrorを実装する必要があります。私はonErrorが常にオブザーバーにあることを理解していますが、RxView.clicks（myview）が実際にonErrorを呼び出すケースがありますか？ RxView.clicks(buttonView).ignoreElements().subscribeWith(new DisposableCom

0熱

1答えて

FutureCallback to Observable

FutureCallbackからObservableを作成する方法はありますか？ Observable.createは推奨されておらず、そのための正しい方法ではありません（下記参照）。私は Observable.create(new Observable.OnSubscribe<HttpResponse>() { @Override public void call(Su

0熱

1答えて

RxJavaで複数のオブザーバブルをチェーンする方法は？

アクティビティonDestroyが呼び出されたときに、いくつかのオペレーションを実行しようとしています。 ObservableをIDで開始し、Realmからいくつかのデータを取得し、取得したデータに基づいてバックエンドにHTTP要求を実行し、その後に取得したデータを開始IDで指定された行に格納します。概要：ストアステップからIDと行にデータを取得バックエンドへの要求を実行するためのIDで使

0熱

1答えて

なぜ複数のRXJavaオブザーバブルで並列実行が行われないのですか？

私はRxJavaに新しいですし、リンクから複数の観測のための並列実行の例を実行しようとしていた。 RxJava Fetching Observables In Parallel 上記のリンクで提供された例は、並行して観測を行っているが、私はスレッドを追加したとき。 sleep（TIME_IN_MILLISECONDS）forEachメソッドでは、システムはObservableを一度に1つずつ実行し

1熱

1答えて

Rxjava - 現在の代わりに他のタイプのストリーム（戻り値）を取得する方法を観測するとき？

私は実行retrofit2観察可能なコールを持っており、それがdb.Itに結果を格納する別の観測可能にそれにチェーンを完了した直後には、単に次のようになります。 protected Observable<List<Long>> buildUseCaseObservable() { return mDataRepo.fetchCountries().flatMap(new Functio

4熱

1答えて

Rxを使用して複数のオブザーバを管理してサービスへの接続を1つだけ維持するにはどうすればよいですか？

私のアプリケーションでは、いくつかのアクティビティがサーバーから情報を取得するため、データを取得する前に接続が確立されていることを確認する必要があります。私はBehaviorSubjectを使用して、接続が確立されたときにサブスクライバに通知し、アクティビティがデータをロードできるようにします。同じフロー内に複数のアクティビティが同じ動作をするという問題があります。私たちのAPIでは、onSta

0熱

1答えて

RxJavaでSchedulers.io（）の動作を変更できますか？

this questionによれば、Schedulers.io()は無限の数のスレッドを作成します。私のアプリケーションでは、完了するために何百もの非同期タスクがあるので、これは問題です。コメントに勧告は妥当であるScheduler.from(Executors.newFixedThreadPool(n))を、使用することですが、使用パターンはSchedulers.io()に異なっている：私は、

1熱

2答えて

GroupedFluxのFluxをバッファリングするにはどうすればよいですか？

Flux FluxのReactorでバッファリング処理を実装しようとしています。内部フラックスの各エミッションは、いくつかの属性によってグループ分けされ、バッファ期間が終了した後に放出されます。（問題を露出させるために簡略化）以下の試験は、所望の挙動を示す： private static final long STEP_MILLIS = 50; private static final Du

1熱

1答えて

RxJavaで複数の.subscribe（）ステートメントを使用する

BLE周辺機器用の私のAndroidアプリは、2つの異なるデバイス特性に書き込み、2つのデバイス特性から通知を受け取ります。 RxAndroidBleライブラリの開発者は同じRxBleConnectionインスタンス上の複数のサブスクリプションに対して注意しますが、これらのI/O操作をすべて単一の.subscribe()に結合する現実的な方法はありません。特に、通知の1つがかなり一定のデータ "消