にrx.Observableタスクの進行状況を出力する がありますonNext()。onNext()放出が非常に速く発生してObserverが追いつかず、背圧が発生することがあります。からの最新の放出のみをバッファリングすることで、背圧を処理したいと思いObservableます。
例えば：
Observable1を発行し、 1をObserver受け取ります。- 1を
Observerまだ処理している間に、 2、3、および4を発行します。Observable Observer処理1を終了し、処理4を開始します(放出2と3はドロップされます)。
これは、Rx Observable で進行状況を処理する一般的なケースのようです。これは、通常、UI を最新の進行状況情報で更新することだけに関心があるためです。しかし、私はこれを行う方法を理解することができませんでした。
RxJavaでこれを達成する方法を知っている人はいますか?