Android RxJava应用：功能防抖

Carson.Ho

发布于 2022-03-25 14:18:22

8600

文章被收录于专栏：Android知识分享Android知识分享

前言

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

今天，我将为大家带来 Rxjava创建操作符的常见开发应用场景：功能防抖需求 ，并结合Retrofit 与RxJava 实现，希望大家会喜欢。

Carson带你学RxJava系列文章，包括 原理、操作符、应用场景、背压等等，请看文章：Android：这是一份全面 & 详细的RxJava学习指南

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事件作出响应");
                    }
                });