首页 > 解决方案 > 我可以在 PublishSubject 上使用哪一组 RxJava 运算符,它会延迟除第一项之外的所有内容,然后在延迟期间跳过除最后一项之外的所有内容?

问题描述

我正在尝试在具有以下属性的 PublishSubject 上构造一个 RxJava 序列:

  1. 订阅者没有延迟地接收到第一个值。
  2. 所有后续值在上一次交付给订阅者之后延迟 1 秒。
  3. 如果在此期间观察到 >1 值,则除最后一个之外的所有值都将被丢弃。

大理石图将是:

1   2   3   4   5       2   3   4

< ----- 1 second ------><--- 1 second ----->

1                       5                   4

标签: rx-java

解决方案


原来throttleLatest是我要找的。


推荐阅读