正文

前言

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

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

• RxJava 如此受欢迎的原因，在于其 提供了丰富 & 功能强大的操作符，几乎能完成所有的功能需求
• 今天，我将为大家带来 Rxjava 创建操作符的 常见开发应用场景：联想搜索优化需求 ，并结合 Retrofit 与 RxJava 实现，希望大家会喜欢。

1. 本系列文章主要基于 Rxjava 2.0
2. 接下来的时间， 我将持续推出 Android 中 Rxjava 2.0 的一系列文章，包括原理、操作符、应用场景、背压等等 ，有兴趣可以继续关注 Carson_Ho的安卓开发笔记 ！！

---

目录

---

1. 需求场景

---

2. 功能说明

注：关于 Rxjava 中的 debuounce（） 操作符的使用请看文章： Android RxJava：过滤操作符 全面讲解

---

3. 具体实现

• 布局文件： activity_filter.xml

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:orientation="vertical"
    android:gravity="center"
    android:layout_width="match_parent"
    android:layout_height="match_parent">

// 用于输入搜索的字符
    <EditText
        android:id="@+id/ed"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:hint="输入搜索字段"
        />

// 用于显示联想搜索的结果
    <TextView
        android:id="@+id/tv"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        />
</LinearLayout>

• 主文件： FilterUsage.java

// 控件绑定
        EditText ed;
        TextView tv;
        ed = (EditText) findViewById(R.id.ed);
        tv = (TextView) findViewById(R.id.tv);
        
         /*
         * 说明
         * 1. 此处采用了RxBinding：RxTextView.textChanges(name) = 对对控件数据变更进行监听（功能类似TextWatcher），需要引入依赖：compile 'com.jakewharton.rxbinding2:rxbinding:2.0.0'
         * 2. 传入EditText控件，输入字符时都会发送数据事件（此处不会马上发送，因为使用了debounce（））
         * 3. 采用skip(1)原因：跳过 第1次请求 = 初始输入框的空字符状态
         **/
        RxTextView.textChanges(ed)
                .debounce(1, TimeUnit.SECONDS).skip(1)
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<CharSequence>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }
                    @Override
                    public void onNext(CharSequence charSequence) {
                        tv.setText("发送给服务器的字符 = " + charSequence.toString());
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.d(TAG, "对Error事件作出响应" );

                    }

                    @Override
                    public void onComplete() {
                        Log.d(TAG, "对Complete事件作出响应");
                    }
                });

• 测试结果

---

4. Demo地址

Carson_Ho的Github地址 = RxJava2实战系列：联想搜索优化

---

5. 总结

• 本文主要讲解了 Rxjava 的实际开发需求场景：联想搜索优化需求
• 下面我将结合 实际场景应用 & Rxjava 的相关使用框架（如 Retrofit 、 Eventbus ） ，继续对 Android 中 Rxjava 的实际开发需求场景进行深入讲解 ，有兴趣可以继续关注 Carson_Ho的安卓开发笔记

---

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

相关文章阅读

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