java实现debounce_Debounce

java实现debounce_Debounce##Debounce仅在过了一段指定的时间还没发射数据时才发射一个数据![debounce](https://box.kancloud.cn/401d51d142852785a558f9eb59212243_1508x584.png)`Debounce`操作符会过滤掉发射速率过快的数据项。RxJava将这个操作符实现为`throttleWithTimeout`和`debounce`。注意:这个操…

大家好,又见面了,我是你们的朋友全栈君。

## Debounce

仅在过了一段指定的时间还没发射数据时才发射一个数据

![debounce](https://box.kancloud.cn/401d51d142852785a558f9eb59212243_1508x584.png)

`Debounce`操作符会过滤掉发射速率过快的数据项。

RxJava将这个操作符实现为`throttleWithTimeout`和`debounce`。

注意:这个操作符会会接着最后一项数据发射原始Observable的`onCompleted`通知,即使这个通知发生在你指定的时间窗口内(从最后一项数据的发射算起)。也就是说,`onCompleted`通知不会触发限流。

### throttleWithTimeout

![debounce](https://box.kancloud.cn/4dbf80628e4f900cbc5ba998812948f7_1280x620.png)

`throtleWithTimeout/debounce`的一个变体根据你指定的时间间隔进行限流,时间单位通过`TimeUnit`参数指定。

这种操作符默认在`computation`调度器上执行,但是你可以通过第三个参数指定。

* Javadoc: [throttleWithTimeout(long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#throttleWithTimeout(long,%20java.util.concurrent.TimeUnit)) and [debounce(long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#debounce(long,%20java.util.concurrent.TimeUnit))

* Javadoc: [throttleWithTimeout(long,TimeUnit,Scheduler)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#throttleWithTimeout(long,%20java.util.concurrent.TimeUnit,%20rx.Scheduler)) and [debounce(long,TimeUnit,Scheduler)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#debounce(long,%20java.util.concurrent.TimeUnit,%20rx.Scheduler))

### debounce

![debounce](https://box.kancloud.cn/c1929f6e9b7312b7d534ac278ea5f9f7_1280x850.png)

`debounce`操作符的一个变体通过对原始Observable的每一项应用一个函数进行限流,这个函数返回一个Observable。如果原始Observable在这个新生成的Observable终止之前发射了另一个数据,`debounce`会抑制(suppress)这个数据项。

`debounce`的这个变体默认不在任何特定的调度器上执行。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/151544.html原文链接:https://javaforall.net

(0)
上一篇 2022年6月20日 上午8:36
下一篇 2022年6月20日 上午8:36


相关推荐

  • 启动磁盘不能被分区或恢复成单个分区 mac_mac如何恢复成单个分区

    启动磁盘不能被分区或恢复成单个分区 mac_mac如何恢复成单个分区最近在MacbookPro2015款上面用bootcamp装了一个widow系统,因为一些不知道的原因,安装玩之后Mac还有一个OSXRESERVED磁盘,这个盘正常情况下安装完window会还给Mac,现在肯定是出现了一些问题。在终端里面输入diskutillist看到#:TYPENAMESIZE

    2022年8月11日
    15
  • PHP进阶与redis锁限制并发访问功能示例

    PHP进阶与redis锁限制并发访问功能示例

    2021年10月27日
    43
  • GPU服务器的用处是什么?跟普通服务器有什么区别?

    GPU服务器的用处是什么?跟普通服务器有什么区别?

    2022年2月19日
    64
  • 详细设计文档模板

    详细设计文档模板原文地址 https www cnblogs com hellowzl p 11511922 html 详细设计文档模板 文件名称 文件版本 V1 0 文档编号 总页数 共页

    2026年3月18日
    2
  • 信息搜集 – 二层发现 arping[通俗易懂]

    信息搜集 – 二层发现 arping[通俗易懂]0x00:简介在被动信息搜集工作完成后,需要在进一步的对目标进行主动信息搜集,这一阶段主要搜索的信息包括目标主机是否存活,上面开放了哪些端口,有哪些服务,服务系统是什么,开发服务的版本以及上面支撑系统运行的一些中间件或者其他软件的版本(后续可根据版本号查看是否有公开的漏洞问题),在目标主机发现的过程中,不仅要发现目标是否存活,还要发现其整个网段下的其他设备,同时,这些其他设备也应该像目标一样搜…

    2022年5月30日
    41
  • Hadoop体系_集团架构

    Hadoop体系_集团架构目录2.1Hadoop简介2.1.1Hadoop由来2.1.2Hadoop发展历程2.1.3Hadoop生态系统2.2Hadoop的体系架构2.2.1分布式文件系统HDFS2.2.2分布式计算框架MapReduce2.2.3分布式资源调度系统YARN2.2.4三大发行版本2.1Hadoop简介自从大数据的概念被提出后,出现了很多相关技术,其中对大数据发展最有影响力的就是开源分布式计算平台Hadoop,它就像软件发展史上的Win…

    2022年10月17日
    4

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号