問題タブ [rx-kotlin2]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - RxJava2 の onBackpressureBuffer の動作は何ですか
私がやりたかったのは、ストリームから生成された最新のアイテムを保持する 1 つのアイテムの背圧バッファーを持つ Flowable を用意することです。
Flowable.onBackpressureBuffer(1, () -> {}, BackpressureOverflowStrategy.DROP_OLDEST) を使用しようとしました。しかし、それは私が期待したように動作しません
私が予想した出力は、最後の項目 9,999 を含む整数のシーケンスであり、連続している必要はありません。ただし、0、1、2、3、4 ... などの最初のいくつかの連続した数字のみが印刷され、毎回異なりますが、最後の数字 9,999 は印刷されません。
rx-java2 - 複数のシングルを処理する方法は?
私は、rxjava2 スタブを使用して grpc でメッセンジャー サーバーを作成しています。
私はある種のことを試しました
すべての例よりも見栄えが悪いので、このすべてのシングルを 1 つの行にまとめる方法はありますか?