CombineLatest内部BackpressureStrategy

Question

我有两个数据来源(领域)。我想用combineLatest操作符。

伪码：

Flowable.combineLatest(
  dataSource1
 .observeOn(Schedulers.io(), false, 1),
  dataSource2
 .observeOn(Schedulers.io(), false, 1),
 1
    )
.observeOn(Schedulers.computation(), false, 1)
// processing
.doOnNext(item -> Thread.sleep(1000)
.subscribe();

我对observeOn操作符中缓存的项的数量使用限制(我不需要发出旧的db缓存数据)。

是否有可能从combineLatest运算符的队列中发出最后一项？在实际状态下，将发出所有项。

从db发出的数据具有相对较大的大小。一双是可以的，但更多的就不行了。

Answer 1

试试onBackpressureLatest

Flowable.combineLatest(
    dataSource1
      .onBackpressureLatest()
      .observeOn(Schedulers.io(), false, 1),
    dataSource2
      .onBackpressureLatest()
      .observeOn(Schedulers.io(), false, 1),
    1     
)
.observeOn(Schedulers.computation(), false, 1)
.doOnNext(item -> Thread.sleep(1000)
.subscribe();