rx-java

3熱

1答えて

RxJava - flatmapとconcatMap - なぜサブスクリプションで同じものを注文していますか？

this thread準拠conCatMapとフラットマップは、アイテムが発行される順序によって異なります。だから私はテストを行い、整数の単純なストリームを作成し、どのような順序でそれらが放出されるのか見たいと思った。私は、1から5までの範囲の数字をとり、2つずつ複数の数値を取る小さな観測値を作った。簡単です。ここではflatmapとコードです： myObservable.flatMap(new

3熱

1答えて

RxJava、存在する場合は最初の項目を取得

RxJavaを使用してリストから最初の項目を取得しようとしています。ただし、アイテムが存在しない場合は、エラーをスローする必要はありません。代わりに、私はデフォルトのアイテムを提供することでそれを処理できるようにしたいと思います。以下に作成したコードは、リストの最初の項目を取得する際に正しく機能します。私はそれに.exists()を組み込む方法を理解することはできませんが。 api.getLib

0熱

1答えて

RxAndroidを使用してオブザーバーをレスポンスに追加しますか？

RxJava/Androidを使用してボレーのonResponse()メソッドの応答にオブザーバーを追加する方法を教えてください。私は応答が到着したときを観察し、他のクラスのメソッドをトリガーしたい。

3熱

1答えて

RxJavaの新機能Singleを使用する理由

ドキュメントは、観察可能なことの何この代替についてかなり明確である：シングルクラスは、単一の値応答のための反応性パターンを実装します。ストリームまたは値のベクトルのリアクティブパターンの実装については、Observableを参照してください。 SingleはObservableと同じように動作しますが、単一の正常値またはエラーのみを出力できます（Observableの場合と同様にonComple

0熱

1答えて

RxAndroid間隔が二回の代わりに一度

CODE heartBeatSub = Observable.interval(HEARTBEAT_INTERVAL, TimeUnit.SECONDS) .flatMap(new Func1<Long, Observable<Notification<Response>>>() { @Override public Observable<Notifi

0熱

2答えて

flux.take（x）またはflux.all（..）がすべての排出を待つことはありません

私はIterableの8要素（Flux.fromIterable(..)）から構築されたfluxを持っています。各フラックスの排出量ごとに、メソッドを非同期に呼び出す必要があります。 dispatchOnとpublishOnでうまくいきませんでしたが、最終的にmap(CompletableFuture.supplyAsync(..), executor)で解決してfluxをflux<Comple

1熱

2答えて

RxJavaとRxAndroidの組み合わせですか？

私のシナリオはこのイメージに非常に似ています。アプリのフローは次のようになります。ビューが更新されますする必要があります。 RxAndroidを使用してオブザーバブルを作成し、キャッシュ/ローカルファイルからデータをフェッチします。ビューを更新します。 RetrofitとRxJavaを使用して別のネットワーク呼び出しを行い、Webサービスからの新しいデータで再度ビューを更新します。ローカル

0熱

1答えて

Androidでretrofitを使用してrxjava内のアイテムリストの各反復処理を処理する方法

私はRxJavaプログラミングの初心者ですが、私は改造呼び出しから持っているリストの各繰り返しをどのように処理するかについて質問したいと思います。予定ののGetリスト反復はそれぞれ任命し、ここが私のコードでpatient_idとは、予定のリストに戻って変換subservice_idを得る：基本的に私は何をしたいですこれまで Observable<List<Appointment>> cal

9熱

2答えて

Observable.fromCallable（）をチェックされたExceptionで使用する方法？

Observable.fromCallable()は、単一の関数をObservableに変換するのに最適です。しかし、関数によって投げられるかもしれないチェックされた例外をどうやって処理するのですか？私が見た例のほとんどはラムダと「ちょうどよい」を使っています。しかし、ラムダなしでこれをどうやってやるのですか？それが今でワンライナーだ Observable.fromCallable(() ->

2熱

2答えて

Observable.create（）を使用しない場合のサブスクリプションステータスを確認する方法は？

は、あなたが観測可能で包まれたいくつかの長い実行中のタスクがあるとしましょう： Observable.fromCallable(new Callable<String>() { @Override public String call() throws Exception { return longRunningTask(); } } は、観察は、我