菜单

实战知识梳理

2019年4月4日 - 注册免费送38元体验金

BMWX三xJava二 实战体系作品

GL450xJava2 实战知识梳理(壹) – 后台执行耗费时间操作,实时通报 UI
更新

路虎极光xJava二 实战知识梳理(2) –
总计壹段时间内数据的平均值

TiggoxJava二 实战知识梳理(3) –
优化搜索联想成效

KugaxJava二 实战知识梳理(四) – 结合 Retrofit
请求新闻资源消息

牧马人xJava二 实战知识梳理(五) –
简单及进阶的轮询操作

RAV肆xJava二 实战知识梳理(六) –
基于错误类型的重试请求

奥迪Q7xJava二 实战知识梳理(7) – 基于 combineLatest
完毕的输入表单验证

RAV4xJava二 实战知识梳理(捌) – 使用 publish + merge
优化先加载缓存,再读取网络数据的乞求进度

驭胜xJava2 实战知识梳理(九) – 使用 timer/interval/delay
完成任务调度

凯雷德xJava二 实战知识梳理(10) – 显示器旋转导致 Activity
重建时上升职责

RAV四xJava贰 实战知识梳理(1一) –
检查评定互联网状态并活动重试请求

奥迪Q3xJava二 实战知识梳理(1二) – 实战讲解 publish & replay & share & refCount
& autoConnect

QashqaixJava二 实战知识梳理(一三) –
怎么着使得错误发生时不自动甘休订阅关系

TiguanxJava二 实战知识梳理(14) – 在 token 过期时,刷新过期 token
一碗水端平新发起呼吁

MuranoxJava二 实战知识梳理(一五) – 完成多个简短的 MVP + RubiconxJava + Retrofit
应用


一、示例

一.一 应用场景

差那么一点各类应用程序都提供了探寻效果,有个别应用还提供了寻找联想。对于1个查找联想效率,最主题的兑现流程为:客户端通过EditTextaddTextChangedListener艺术监听输入框的转变,当输入框发生变化之后就会回调afterTextChanged主意,客户端应用近来输入框内的文字向服务器发起呼吁,服务器重临与该搜索文字关联的结果给客户端举办展现。

在本场景下,有多少个能够优化的下面:

一.二 示例代码

此处,大家本着地方提到的三个难点,使用RxJava2提供的多个操作符进行了优化:

public class SearchActivity extends AppCompatActivity {

    private EditText mEtSearch;
    private TextView mTvSearch;
    private PublishSubject<String> mPublishSubject;
    private DisposableObserver<String> DisposableObserver;
    private CompositeDisposable mCompositeDisposable;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_search);
        mEtSearch = (EditText) findViewById(R.id.et_search);
        mTvSearch = (TextView) findViewById(R.id.tv_search_result);
        mEtSearch.addTextChangedListener(new TextWatcher() {

            @Override
            public void beforeTextChanged(CharSequence s, int start, int count, int after) {

            }

            @Override
            public void onTextChanged(CharSequence s, int start, int before, int count) {

            }

            @Override
            public void afterTextChanged(Editable s) {
                startSearch(s.toString());
            }
        });
        mPublishSubject = PublishSubject.create();
        DisposableObserver = new DisposableObserver<String>() {

            @Override
            public void onNext(String s) {
                mTvSearch.setText(s);
            }

            @Override
            public void onError(Throwable throwable) {

            }

            @Override
            public void onComplete() {

            }
        };
        mPublishSubject.debounce(200, TimeUnit.MILLISECONDS).filter(new Predicate<String>() {

            @Override
            public boolean test(String s) throws Exception {
                return s.length() > 0;
            }

        }).switchMap(new Function<String, ObservableSource<String>>() {

            @Override
            public ObservableSource<String> apply(String query) throws Exception {
                return getSearchObservable(query);
            }

        }).observeOn(AndroidSchedulers.mainThread()).subscribe(DisposableObserver);
        mCompositeDisposable = new CompositeDisposable();
        mCompositeDisposable.add(mCompositeDisposable);
    }

    private void startSearch(String query) {
        mPublishSubject.onNext(query);
    }

    private Observable<String> getSearchObservable(final String query) {
        return Observable.create(new ObservableOnSubscribe<String>() {

            @Override
            public void subscribe(ObservableEmitter<String> observableEmitter) throws Exception {
                Log.d("SearchActivity", "开始请求,关键词为:" + query);
                try {
                    Thread.sleep(100 + (long) (Math.random() * 500));
                } catch (InterruptedException e) {
                    if (!observableEmitter.isDisposed()) {
                        observableEmitter.onError(e);
                    }
                }
                Log.d("SearchActivity", "结束请求,关键词为:" + query);
                observableEmitter.onNext("完成搜索,关键词为:" + query);
                observableEmitter.onComplete();
            }
        }).subscribeOn(Schedulers.io());
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        mCompositeDisposable.clear();
    }
}

运作结果为:

注册免费送38元体验金 1

2、示例解析

上面,我们就来详细的牵线一下以此例子中利用到的二种操作符

2.1 debounce

debounce的法则图如下所示:

注册免费送38元体验金 2

debounce规律类似于大家在收取请求之后,发送三个延时新闻给下游,假诺在这段延时时间内并没有接受新的伏乞,那么下游就会吸收该音信;而假设在那段延时时间内收取来新的呼吁,那么就会撤废在此之前的音信,同仁一视新发送3个新的延时消息,以此类推。

而若是在那段日子内,上游发送了onComplete消息,那么即使未有到达供给静观其变的小运,下游也会应声接到该新闻。

2.2 filter

filter的规律图如下所示:

注册免费送38元体验金 3

filter的原理很不难,就是流传1个Predicate函数,其参数为上游发送的事件,唯有该函数重临true时,才会将事件发送给下游,不然就废弃该事件。

2.3 switchMap

注册免费送38元体验金 4

switchMap的原理是将上游的事件转换成3个或七个新的Observable,但是有几许很关键,正是假如在该节点收到贰个新的风云之后,那么只要在此之前收到的光阴所发生的Observable还尚未发送事件给下游,那么下游就再也不会收到它发送的风云了。

如上海教室所示,该节点先后吸收接纳了红、绿、蓝八个事件,并将它们映射成为红1、红2、绿一、绿二、蓝一、蓝贰,可是当蓝一发送完事件时,绿二仍然未有发送事件,而早期铁青事件在深蓝事件此前,那么绿二就不会发送给下游。


越多作品,欢迎访问小编的 Android 知识梳理种类:

相关文章

发表评论

电子邮件地址不会被公开。 必填项已用*标注

网站地图xml地图