rx-java

0熱

1答えて

私はonNextを呼び出してからonErrorメソッドを呼び出したいと思います。しかし、私はそれをすることはできません。誰か助けてくれますか？例： Observable.create(new ObservableOnSubscribe<String>() { @Override public void subscribe(ObservableEmitter<String> e)

1熱

1答えて

Vertx eventbus rx exceptionhandling

リクエスト・リプライ・パターンでVertx eventbusを使用すると、私は回避したい重複した例外処理を行います。は、私は次のコードを持っている： void handle(Message<JsonObject> message) { try { // do stuff message.reply(..); } catch (Exception e)

1熱

2答えて

RxJava 2.xを使用して2つ以上のObservablesを使用することは可能ですか？

私はRxJava 2.xを使用していますが、3つの観測点を持っています（重要なのは、特に被写体を公開する場合です）。私はそれらを一度すべて実行し、一度結果を得るのが好きです。私はObservable.zip()オペレータをこの種のプロセスに使用していました。しかし、Zip演算子は2つ以上の観測値をサポートしていないようです。 zipのように3つ以上の観測値を組み合わせる演算子はありますか？実際

0熱

1答えて

Observable Waiting for Observable subscribe to finish

私は現在RxJavaの使い方を学んでおり、データベースからフェッチされたデータを計算して非同期に計算したいが、すべてのデータが計算されるのを待っている。 List<Data> list = getDatasFromDatabase(); list.forEach(data -> compute(data)); // How can I make this async using RxJava

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熱

2答えて

rxjavaはダウンストリームの結果をドロップします

私はAPI呼び出しを行うためのrxメソッドを持っていますが、このメソッドの呼び出し元は非常に短時間で複数回発生する可能性があります。だから、RXメソッドは、呼び出し元のメソッドは、これは短時間で複数回apiCallWithRx呼び出すことができます public void apiCallWithRx() { apiService.makeApiCall() .subscrib

1熱

2答えて

どのようにセットアップするのが最適です部屋と改装工事

私は現在、改装をして部屋を設定しようとしています。私はその後ApiDatabaseがSingle<ApiItem>にApiItemBeanでデータベース化したり、新しいApiItemをマッピングするためにそのApiItemDAOを呼び出して、それがApiItemBeanを要求... 作業の実装を持っています。このシングルは、ApiRepositoryでApiRequestで使用され、最終的には、