問題タブ [rx-kotlin2]

基本的に、私は2つFlowables Fあり、それらでG使用したいのですが、完了した場合（まだ実行中であっても）combineLatest、結合Flowableされたものがすでに完了していることを望みます。FG

これは、醜いソリューションで何を達成するかの例です。

それを拡張関数に抽出できます。

それを表現するより良い方法はありますか？

ブロッキング IO 呼び出し (HTTP 呼び出しなど) を行うチェーンがあります。ブロッキング呼び出しで値を消費し、中断せずに続行しますが、その間に積み重なったものはすべて破棄し、同じ方法で次の値を消費します。

次の例を検討してください。

単純な観点からは、 のようなものを出力することを期待します0, 10, 20, ...が、 を出力し0, 1, 2, ...ます。

私は何を間違っていますか？

編集：

debounce受信ストリームを食い尽くすために素朴に追加することを考えました：

しかし、今、私はjava.lang.InterruptedException: sleep interrupted.

編集：

動作しているように見えるのは次のとおりです。

出来上がりは期待通り0, 10, 20, ...!!

それは正しい方法ですか？

throttleLastComputation-Scheduler に切り替えることに注意しました。元のスケジューラに戻す方法はありますか?

編集：

私はまたjava.lang.InterruptedException: sleep interrupted、その変種で時折得ます。