专栏名称: Carson_Ho
1. 简书认证作者、CSDN签约作者、稀土掘金专栏作者 2. 专注分享 Android开发干货 3. 博客地址 Github: https://github.com/Carson-Ho CSDN: http://blog.csdn.net/carson_ho 稀土掘金: https://juejin.im/user/58d4d9781b69e6006ba65edc
目录
相关文章推荐
开发者全社区  ·  突发:DeepSeek被封杀 ·  昨天  
开发者全社区  ·  患者带着DeepSeek来看病,医学博主自嘲 ... ·  昨天  
开发者全社区  ·  邻家弟弟好厉害 ·  2 天前  
开发者全社区  ·  雪圈乱吗? ·  3 天前  
开发者全社区  ·  大佬与梁文锋第一次的接触 ·  3 天前  
51好读  ›  专栏  ›  Carson_Ho

Android RxJava 实际应用讲解:功能防抖

Carson_Ho  · 简书  · android  · 2017-11-29 11:30

正文

前言

  • Rxjava ,由于其 基于事件流的链式调用、逻辑简洁 & 使用简单 的特点,深受各大 Android 开发者的欢迎。
Github截图

如果还不了解RxJava,请看文章: Android:这是一篇 清晰 & 易懂的Rxjava 入门教程

  • RxJava 如此受欢迎的原因,在于其 提供了丰富 & 功能强大的操作符,几乎能完成所有的功能需求
  • 今天,我将为大家带来 Rxjava 创建操作符的 常见开发应用场景:功能防抖需求 ,并结合 Retrofit RxJava 实现,希望大家会喜欢。
  1. 本系列文章主要基于 Rxjava 2.0
  2. 接下来的时间, 我将持续推出 Android Rxjava 2.0 的一系列文章,包括原理、操作符、应用场景、背压等等 ,有兴趣可以继续关注 Carson_Ho的安卓开发笔记 !!
示意图

目录

示意图

1. 需求场景

示意图

2. 功能说明

示意图

注:关于 Rxjava 中的 throttleFirst() 操作符的使用请看文章: Android RxJava:过滤操作符 全面讲解


3. 具体实现

// 注册控件
        Button button;
        button = (Button)findViewById(R.id.button);

        /*
         * 1. 此处采用了RxBinding:RxView.clicks(button) = 对控件点击进行监听,需要引入依赖:compile 'com.jakewharton.rxbinding2:rxbinding:2.0.0'
         * 2. 传入Button控件,点击时,都会发送数据事件(但由于使用了throttleFirst()操作符,所以只会发送该段时间内的第1次点击事件)
         **/
        RxView.clicks(button)
                .throttleFirst(2, TimeUnit.SECONDS)  // 才发送 2s内第1次点击按钮的事件
                .subscribe(new Observer<Object>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }
                    @Override
                    public void onNext(Object value) {
                        Log.d(TAG, "发送了网络请求" );
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.d(TAG, "对Error事件作出响应" + e.toString());
                        // 获取异常错误信息
                    }

                    @Override
                    public void onComplete() {
                        Log.d(TAG, "对Complete事件作出响应");
                    }
                });
  • 测试结果
    2s 内,无论点击多少次,也只会发送1次网络请求
    示意图

4. Demo地址

Carson_Ho的Github地址 = RxJava2实战系列:功能防抖


5. 总结

  • 本文主要讲解了 Rxjava 的实际开发需求场景:功能防抖需求
  • 下面我将结合 实际场景应用 & Rxjava 的相关使用框架(如 Retrofit Eventbus ,继续对 Android Rxjava 的实际开发需求场景进行深入讲解 ,有兴趣可以继续关注 Carson_Ho的安卓开发笔记

请点赞!因为你的鼓励是我写作的最大动力!

相关文章阅读







请到「今天看啥」查看全文


推荐文章
开发者全社区  ·  突发:DeepSeek被封杀
昨天
开发者全社区  ·  邻家弟弟好厉害
2 天前
开发者全社区  ·  雪圈乱吗?
3 天前
开发者全社区  ·  大佬与梁文锋第一次的接触
3 天前
程序员技术  ·  让编程更轻松的 7 个 Visual Studio 扩展
7 年前