rx-java2

10熱

2答えて

私はRx 1からRx 2に移行中です。ポストを読んでいるうちに、Singleが改造呼び出しに使用する観測可能なタイプであることがわかりました。私はそれを打つことに決めました。私たちのレトロフィットコールをRx 2に移行する間に、戻り値もSingle<whatever>に変更されました。ご覧のように前に我々は単にへuserServiceモックを伝えることで、ストリームを完了するために使用されるコー

5熱

2答えて

RxJava 2.Xのブール値ゲートに基づいて観測値を一時停止し、再開しますか？

私は、ボタンを押したときにブール値を出すProcessorを持っているとしましょう。これをトグルと考えてください。私がやりたい何 boolean gateValue = true; PublishProcessor<Boolean> gate = PublishProcessor.create(); view.onButtonClicked() .subscrib

0熱

1答えて

RxJava2：ストリーム全体に与えられたスケジューラを適用しますか？

私はPublishSubject<Item>（B）は新しいItemを持つたびに、そのアイテムを発する（A）Observable<Item>を持っています。は、その後、A.subscribeOn(computationScheduler).observeOn(mainThread) 目標として使用されます。が計算-スケジューラでその作業を行い、その後、メインスレッド上で結果を消費から完全なストリー

4熱

1答えて

rxjava2のメソッド 'subscribe（anonymous io.reactivex.functionx.Consumer <java.util.List <...>>）'を解決できませんか？

toList演算子が実行した後、元々Flowable < < \ List >>に変換します。< < \ List >>私がSingleを購読するConsumerを作成すると、 Consumerの値の型はObject以外では変更できません。私のコメントから @Override public void loadBannerData(final ADFilterType adFilterType)

1熱

1答えて

JDK8でAndroid上でRxJava2を使用してログインボタンを有効にする

RxJava2を使用してユーザー名とパスワードが十分に長いのにログインボタンを有効にしたいがエラーが発生する。そしてa && bのエラーがあり、他のエラーがあるが、私は考えている：あなたは、これは誤りであるmap(inputTextを参照してください両方のセクションのために final Button loginButton = (Button) view.findViewById(R.id.l

2熱

1答えて

RxJava2：パラレルデータのダウンロードとキャッシングを改善するには？

私はRxJava2を通して自分のやり方と戦っています。私の解決策が受け入れ可能かどうか、それを改善する方法があるのだろうかと思います。いくつかのバックエンド呼び出しはできるだけ早くこれらの仕上げのいずれかのよう並列に処理されるまで待機してください - - データユースケースユーザーはダイアログが表示され、更新データボタンを押しますローカルデータベースに保存されますすべての要求が完了した

1熱

1答えて

RxJava2に多数のサブスクライバを持つ単一の非同期イベント

私は、プロセスを遅くする可能性のあるイメージを処理するクラスを持っています。作業が完了すると、クラスには支配的な色のようなイメージに関するいくつかの特徴が含まれます。私は、支配的な色を知りたい多くのコードを持っています。彼らが要求すると、準備ができているかもしれません。 RxJava2を使用してこれを実装する簡単な方法はまだありません。誰か助けてくれますか？は、複数の加入者が購読/呼び出すこと

8熱

1答えて

RxJava 2.0 - ObservableをPublisherに変換する方法

ObservableをRxJavaバージョン2のPublisherに変換するにはどうすればよいですか？最初のバージョンでは、私が必要とするものを正確に実行するhttps://github.com/ReactiveX/RxJavaReactiveStreamsプロジェクトがあります。しかし、RxJava 2でどうすればいいですか？

1熱

1答えて

Vertex HttpClientとRxJavaでの背圧

「背圧システム」を作成する際に問題があります。私はVertx HttpClientとRxJavaを使っています。私は外部サービスに対して6000リクエストを行う必要があり、waitingForQueueでいっぱいになるのを避けるために、この外部サービスは送信するほど速く処理できないため、リクエスト/レスポンスの間に遅延があります。この旅行はバッチ処理として機能しているので、1分かかっても心配は