concatmap

0熱

1答えて

Rx.Observable.prototype.fromEvent（）の奇妙な動作

今日、私はRxJSを使用するときに奇妙な問題を見ました。それを調べるのを手伝ってください。 私が取り組んでいる問題は次のとおりです。「画像URLの配列を指定すると、すべての画像をロードしてdivに追加する」 すべてのコードスニペットを実証するためには、ここにある：初め https://pastebin.com/F3ZkH3F8 、私はthe first snippetを使用。 ただし、Rx.Obs

javascript jquery rxjs flatmap concatmap 2017-05-25

---

0熱

1答えて

RxJava 2 - concatMapのキューを減らす

私はいくつかのデータを送信するサブジェクトがあります。次に、キュー内のこのデータを変更したい（長い操作）。しかし、別の主題は、今、私はそれらの要素がすでにconcatMap（によって消費されていない場合otherSubject（3と4）でemitedの要素をスキップするために私の使い捨てを変更したい、私は PublishSubject<Integer> myBaseSubject = Publis

java android queue rx-java2 concatmap 2017-12-13

---

1熱

1答えて

ConcatMapがsetDataメソッドは、任意の中間ノードのエラーを投げている場合は、エラーが1観測可能

に、私はここで `Observable.from(modifiedNodes) .concatMap(node => { return this.Model.setData(node); }) .subscribe( () => { NodeSaved++;

rxjs observable concatmap 2017-06-06

---

1熱

2答えて

Observable concatMapは何らかの理由でメインスレッド上のものを実行します

Observablesのチェーンがあり、すべてが終了した後に終了するダイアログがあります。 1 api call get ResponseBody 2レスポンスボディプロセスを取る 他の3つのプロセス（UIスレッドではない） 最初の呼び出しでは、ダイアログが正常に表示され、2番目の呼び出しでダイアログがブロックされ、最初の呼び出しの本文が表示されます。残りの時間です。 すべてが完了した後、最後に警

android multithreading rx-java observable concatmap 2016-08-14

---

3熱

1答えて

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

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

rx-java flatmap concatmap 2016-03-21

---