rx-java - 我可以在 PublishSubject 上使用哪一组 RxJava 运算符,它会延迟除第一项之外的所有内容,然后在延迟期间跳过除最后一项之外的所有内容?
问题描述
我正在尝试在具有以下属性的 PublishSubject 上构造一个 RxJava 序列:
- 订阅者没有延迟地接收到第一个值。
- 所有后续值在上一次交付给订阅者之后延迟 1 秒。
- 如果在此期间观察到 >1 值,则除最后一个之外的所有值都将被丢弃。
大理石图将是:
1 2 3 4 5 2 3 4
< ----- 1 second ------><--- 1 second ----->
1 5 4
解决方案
原来throttleLatest
是我要找的。
推荐阅读
- python - Python PIL - 将多层图像合并为一个
- python - 考虑到颜色的细微差别
- sql - 使用 Null 和自定义存储桶求和
- eclipse - Java构建路径配置
- android - Android 模拟器未在 AMD 处理器上运行
- python - 是否可以从 bash CGI 脚本调用 python 脚本?
- android - 错误:“java.lang.String 类型的值 br 无法转换为 JSONArray”
- typescript - 在没有三斜杠引用的 Angular 库中使用 typings.d.ts
- python - 程序在第一部分代码之后没有继续
- php - Symfony + VueJs + Axios = 无发送表单参数