rx-java2

2熱

1答えて

とのAPIを呼び出すときに私が言及したLIBSとAPIを呼び出すことに問題がある私の依存関係を怒鳴る：改造インスタンス @Provides @Singleton RxJava2CallAdapterFactory provideRxJavaCallAdapter(){ return RxJava2CallAdapterFactory.createWithScheduler(Sche

1熱

1答えて

flatMapFirst：前のものが終了した場合にのみ新しい観測値を追加するflatMap

flatMapFirstの演算子を実装する方法は、flatMapのようになりますが、前のものが終了した場合のみ新しい観測値を追加しますか？以前のものがまだ実行されている場合は、新しいobservableを無視します。どのようにRxJava 2でそれを実装するには？すでにベーコンに存在します。 - flatMapFirst kefir - flatMapFirstにあります。 source.onB

1熱

1答えて

RxJava 2.x：serialize（）が機能しない

sereialize()をテストするために以下を試しました。私はonNextを1,000,000回呼び出して、2つの異なるスレッドから数えました。次に、私はonCompleteに2,000,000を得ることを期待しました。しかし、私は期待値を得ることができませんでした。 private static int count = 0; private static void setCount(

4熱

1答えて

RxJava1：onNext

の例外RxJava1で次の操作を実行すると、onNextで例外が同じ加入者のonErrorに再ルーティングされることになります。 Observable.from(Arrays.asList("1", "22", "333", "4444")).subscribe(new Subscriber<String>() { @Override public void onCompl

1熱

1答えて

doOnNext内にスローされたRxJavaの再試行

AIM：何かが変更されたときに、ユーザーがリストをスクロールしなくても、アダプタを更新します。 doOnNextにエラーをスローして、もう一度やり直すことができます。しかし、これは動作していません。私は例外がスローされていることがわかりますが、retryWhenは何もしていないようです。私はここで間違っていますか？ someObservable() .observeOn(Android

0熱

1答えて

保存が発生したときにモデルをトリガーして新しいデータを与える方法

私は、次のことを行う方法を見つけようとしています：私のアプリが開くと、データレイヤの購読によってデータのグリッドビューが読み込まれます観察可能である。私が理解しようとしているのは、ユーザーがhidボタンをクリックするかグリッドアイテムを非表示にしたり、アイテムを並べ替えたりするなど、グリッドビューに何らかのデータ変換を行う方法です。何かのリストにデータを更新しました。私の目標は、どのクラスでもこ

1熱

1答えて

RxJava 2 + Retrofit 2（または長い非同期タスク）+ Dagger 2 + MVP VS方向を変える

RxJavaと長いタスクで向きを変えて処理する方法を学び、断片を保持してviewstateを保存する方法について読んでいますが、それでも私にとってはまだ不明です。たちは改造を経由してネットワーク要求を持っている、と想像： Retrofit retrofit = ApiClient.getClient(); //get retrofit instance retrofit.create(

2熱

1答えて

RxJavaがリスト上で操作を実行してオブザーバブルを返す

RxJava（特にRxJava2）を使い慣れていないので、比較的簡単な操作であるように見えます。私は、データベースからいくつかのデータを取得する必要があります（それは、リストとして表される）データを反復処理、各項目の操作を実行し、別のオブジェクトにデータをラップして戻ります。これは私が今までに持っているものです：問題は私のデータマネージャーが決して完了しないということです。基本的なデータが変更さ

0熱

1答えて

Rxjava2 + Google SignIn In Firebase

RxJavaのアプローチを使用して、私のアプリケーションにFirebus用のGoogle SignInを統合しようとしています。しかし何らかの理由でそれは遅いです。私はこの問題を解決するために私のアプローチで入れ子Observablesを使用しています。誰かがこの問題のより効率的な解決法を提案することができますか？ Googleのサインインボタンをこの私のコードへのステップバイステップのチュート

0熱

1答えて

oncomplete（Rxjava2）でobservableを使用する方法

私はできるだけ多くのrxjavaで自分のアプリケーションを書いていますが、次の問題があります。私は、APIとデータを同期させる方法があり、タイムスタンプに基づいてデータをダウンロードします。だから私は、次のデータの流れをしたいと思います：が最後のタイムスタンプを取得する - >ダウンロードデータ - >保存データ - >更新のタイムスタンプエラーがを発生しましたしない場合、問題は、私は避ける