Android RxJava/RxAndroid:takeWhile,直test测试条件通过才执行链式操作-阿里云开发者社区

开发者社区> 开开心心过> 正文

Android RxJava/RxAndroid:takeWhile,直test测试条件通过才执行链式操作

简介: Android RxJava/RxAndroid:takeWhile,直test测试条件通过才执行链式操作 RxJava/RxAndroid的takeWhile的test测试某一个条件是否达成,若完成,才执行后续的链式操作,若没有达成,则轮询反复的执行test测试,不执行后续操作。
+关注继续查看
Android RxJava/RxAndroid:takeWhile,直test测试条件通过才执行链式操作


RxJava/RxAndroid的takeWhile的test测试某一个条件是否达成,若完成,才执行后续的链式操作,若没有达成,则轮询反复的执行test测试,不执行后续操作。直到test返回fasle退出轮询为止。
在Android中,例如当某个Android的View很复杂,加载时间非常长,那么在异步的对View对象的操作极有可能发生NullPointerException崩溃。
举例,本例故意让mTextView在异步线程中滞后5秒完成初始化。在对mTextView进行操作前,先通过takeWhile方法test测试mTextView是否为null。
若test返回false,takeWhile将立即执行后续观察者的onComplete。
package zhangphil.test;

import android.os.Bundle;
import android.os.Handler;
import android.support.v7.app.AppCompatActivity;
import android.util.Log;
import android.widget.TextView;

import java.util.concurrent.TimeUnit;

import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.functions.Predicate;
import io.reactivex.observers.DisposableObserver;
import io.reactivex.schedulers.Schedulers;

public class MainActivity extends AppCompatActivity {

    private String TAG = "测试输出";
    private TextView mTextView = null;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        new Handler().postDelayed(new Runnable() {
            @Override
            public void run() {
                setContentView(R.layout.activity_main);
                mTextView = findViewById(R.id.text);
            }
        }, 5000);

        //mTextView.setText("代码运行到这里,mTextView还为null,若此时直接对mTextView进行操作,会引发NullPointerException崩溃。");

        refresh();
    }

    private void refresh() {
        DisposableObserver mDisposableObserver = new DisposableObserver<Long>() {
            @Override
            public void onNext(Long l) {
                Log.d(TAG, "onNext:" + l);
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "onComplete");
                update();
            }

            @Override
            public void onError(Throwable e) {
                Log.e(TAG, e.toString(), e);
            }
        };

        //轮询测试。直到当test返回false,才会进入DisposableObserver的结束onComplete。
        //若test返回true,轮询测试仍然循环执行。
        Observable.interval(0, 1, TimeUnit.SECONDS)
                .takeWhile(new Predicate<Long>() {
                    @Override
                    public boolean test(Long aLong) throws Exception {
                        if (mTextView != null) {
                            return false;
                        } else {
                            return true;
                        }
                    }
                }).subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeWith(mDisposableObserver);
    }

    private void update() {
        mTextView.setText("更新!");
    }
}


运行输出:

04-10 15:54:08.475 25916-25916/zhangphil.test D/测试输出: onNext:0
04-10 15:54:09.402 25916-25916/zhangphil.test D/测试输出: onNext:1
04-10 15:54:10.402 25916-25916/zhangphil.test D/测试输出: onNext:2
04-10 15:54:11.403 25916-25916/zhangphil.test D/测试输出: onNext:3
04-10 15:54:12.402 25916-25916/zhangphil.test D/测试输出: onNext:4
04-10 15:54:13.409 25916-25916/zhangphil.test D/测试输出: onComplete

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Datastream 开发打包问题
Datastream作业开发时往往会遇到一些jar包冲突等问题,本文主要讲解作业开发时需要引入哪些依赖以及哪些需要被打包进作业的jar中,从而避免不必要的依赖被打入了作业jar中以及可能产生的依赖冲突。
39 0
更快的Maven构建工具mvnd和Gradle哪个性能更好?(1)
更快的Maven构建工具mvnd和Gradle哪个性能更好?(1)
16 0
APICloud 原生模块、H5模块、多端组件使用教程
使用APICloud平台,可以使用前端技术快速开发iOS、Android App、小程序、Web等多端应用。在开发过程中,调用模块可以极大的提升开发效率。本文分为三个部分,告诉大家如何使用APICloud 的原生模块、H5模块以及多端组件,快速实现功能开发。
5 0
无影云电脑 - 我和我们的无影云
阿里推出的无影云电脑一些感受
18 0
你真的了解CSS3硬件加速吗?
你真的了解CSS3硬件加速吗?
32 0
用谷歌云自建微软GitHub codespaces和VScode.dev云编译Cloud IDE是怎样一种体验?
你将拥有比微软官方vscode.dev 更强大的vscode谷歌云IDE,你可以随时随地坐在马桶上用599块钱的小米手机登陆网页版vscode开发一款APP,比如:Tiktok;这个网页版vscode比微软GitHub codespaces和VScode.dev官方更强大,它同样拥有terminal,重点是它编译不受本地网络的限制可以远程云编译,高速高效随时随地,而且是使用强大谷歌云服务器进行编译,爽哼! 下一步咱们搞个Android studio网页版云编译平台,好不好,宝? 下下一步咱们使用599块钱的小米手机远程连接网页版vscode和网页版Android studio开发一款安卓ap
8 0
flutter项目如何打包(android)
打包前要做的 1.更换图标 andriod–》app–app–》src—》main-》Java----》res–》minpmap
6 0
flutter分平台主题定制
有时候,为了满足不同平台的用户需求,我们希望针对特定的平台设置不同的样式。比如,在 iOS 平台上设置浅色主题,在 Android 平台上设置深色主题。面对这样的需求,我们可以根据 defaultTargetPlatform 来判断当前应用所运行的平台,从而根据系统类型来设置对应的主题。
4 0
如何搭建一台供自己永久使用的服务器,永久运行自己的网站【再见 云服务器】
如何搭建一台供自己永久使用的服务器,永久运行自己的网站【再见 云服务器】
18 0
682
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载