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


相关推荐

  • Windows 10 下,强制关闭端口

    Windows 10 下,强制关闭端口Windows10下,端口被占用或程序已关闭端口没有正常关闭时,强制关闭端口这种方法的前提是知道被占用的端口号这是我用的一种方法1、打开命令窗口,根据端口号查询这个端口号的PID,以端口号9001为例进入命令窗口执行命令netstat-ano|findstr”9001″如下图查询到端口9001对应的pid为566322、根据查出来的pid强制关闭这个端口号命令…

    2022年7月20日
    52
  • python 读json_python json文件

    python 读json_python json文件python中和json读写相关的主要是json模块的以下四个函数dumps()将一个python对象编码为json对象 loads()讲一个json对象解析为python对象 dump()将python对象写入文件 load()从文件中读取json数据1、dumps()和loads()主要用于Python和json对象的相互转化。importjsonprices…

    2022年10月12日
    3
  • eclipse首选项里面没有Server(eclipse的server视图)

    学习JavaWeb需要安装tomcat,但一直找不到sever选项,很苦恼下面将详细介绍eclipse中servers不见了的解决方法。    ①在软件eclipse下的Help->InstallNewSoftware->中,在Workwith中点击Add,如下,加入Name——"Kepler"repository;Location——http://downlo…

    2022年4月17日
    42
  • f stream_fstream

    f stream_fstreamofstream是从内存到硬盘,ifstream是从硬盘到内存,其实所谓的流缓冲就是内存空间;在C++中,有一个stream这个类,所有的I/O都以这个“流”类为基础的,包括我们要认识的文件I/O,stream这个类有两个重要的运算符:1、插入器(  向流输出数据。比如说系统有一个默认的标准输出流(cout),一般情况下就是指的显示器,所以,cout2、析取器(>>)  从流中输入数据

    2025年11月24日
    7
  • 国产数据库乱象_四代户户通怎么开户

    国产数据库乱象_四代户户通怎么开户其实这篇文章是我周末开始写的,写这篇文章的这个周末,我的很多时候都是在思考一个数据库国产化替代的建设方案,翻阅了大量的资料。今年正好是我参加工作后的第31个年头,工作的最初十年,我写了十年代码,从汇编、COBOL到C语言,写了几十万行代码;随后的十几年,我一直在帮助用户用好数据库,也在帮助Oracle推广RAC技术;2015年开始,我一边继续从事数据库优化的工作,一边在帮助客户如何从Oracle迁移到成本更低的数据库系统上。所以对国产数据库我一直有一种十分特殊的情感,这是一种爱恨交织的情感。所以今天最后用“

    2026年1月27日
    5
  • os.environ[“CUDA_VISIBLE_DEVICES”] 问题

    os.environ[“CUDA_VISIBLE_DEVICES”] 问题有一次写代码发现明明写的是 os environ CUDA VISIBLE DEVICES 0 1 2 3 4 5 6 7 但是却显示只发现了 gpu 0 百思不得其解 百度谷歌都没有发现类似问题 后来检查才发现有一个调用的 py 文件里写了一句 os environ CUDA VISIBLE DEVICES 0 删掉之后 可以发现全部的 gpu

    2026年2月7日
    2

发表回复

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

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