問題タブ [reactivex]

.groupBy と .concatAll の組み合わせで出力をグループ化すると、期待される出力が生成されません。

サンプルコード:

実際の出力:

期待される出力:

これらの演算子の仕組みを誤解していますか? それとも、これは RxJS のバグですか? ( https://github.com/Reactive-Extensions/RxJS/issues/1264ですでにバグとして暫定的に提出されています。)

Observable (ネットワークからデータを取得する) があります。問題は、ネットワークの状態によってオブザーバブルが速くなったり遅くなったりすることです。

オブザーバブルが実行されているときに進行状況ウィジェットを表示し、オブザーバブルが完了すると非表示にします。ネットワークが高速な場合 - 進行状況がちらつきます (表示されては消えます)。オブザーバブルの最小実行時間を1秒に設定したい。どうやってやるの？

「遅延」演算子は、遅いネットワークでも遅延するため、オプションではありません。

RxJSとrx-nodeの違いは何ですか?

NodeJS プロジェクトで rx-node の代わりに RxJS を使用すべきではないのはなぜですか?

私は CycleJS を学習しています。Cycle の HTTP ドライバーを使用しているときに、 response stream streamRxJSswitch/mergeAllを使用してストリーム レベルに到達するためにマージする必要があることがわかりました。しかし、これらの関数を適用しようとすると、型エラーが発生switch is not a functionします: (応答ストリーム ストリームで)。

何か不足している場合はお知らせください。

ネットワーク呼び出しに対して一種の指数バックオフを作成したいと考えています。ただし、通常のバックオフ間隔の代わりに、ネットワーク呼び出しの結果に関係なく、ネットワーク呼び出しを数回 (遅延を増やしながら) 繰り返してから完了する必要があります。

たとえば、デフォルトのケースは次のようになります。

一部のネットワーク呼び出しでエラーが発生した場合、これらのエラーはログに記録されますが、タスク自体は中止されません。2 番目のネットワーク呼び出しにエラーがあるとします。その場合、次のようになります。

そして、すべての呼び出しにエラーがある場合:

コードが次のようなネットワークを呼び出すことができる Observable が既にあります。

loadStuff()Observable を繰り返し使用して目的のバックオフ間隔を達成するにはどうすればよいですか?

I have a report.service.ts that have one simple method to get reports (which is just a const array of reports object from a mock), and all it really does is this:

now in my app.component I want to get those reports. So I did:

this is it, but its not working, obviously im doing something wrong here, im new to observables :/

thanks!