package zhangphil.app;
import android.os.Bundle;
import android.support.annotation.Nullable;
import android.support.v7.app.AppCompatActivity;
import android.util.Log;
import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.functions.Predicate;
import io.reactivex.observers.DisposableObserver;
import io.reactivex.schedulers.Schedulers;
public class MainActivity extends AppCompatActivity {
private final String TAG = getClass().getSimpleName();
private CompositeDisposable mCompositeDisposable = new CompositeDisposable();
@Override
public void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
test();
}
private void test() {
DisposableObserver disposableObserver = new DisposableObserver<Integer>() {
@Override
public void onNext(Integer i) {
Log.d(TAG, "#####开始#####");
Log.d(TAG + "数据", String.valueOf(i));
Log.d(TAG, "#####结束#####");
}
@Override
public void onComplete() {
Log.d(TAG, "onComplete");
}
@Override
public void onError(Throwable e) {
Log.e(TAG, e.toString(), e);
}
};
mCompositeDisposable.add(
getObservable().filter(new Predicate<Integer>() {
@Override
public boolean test(Integer integer) throws Exception {
int result = integer % 10;
boolean b = (result == 0);
return b; // 此处返回的条件若为true，则数据交给观察者 ,否则跳过
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeWith(disposableObserver));
}
private Observable<Integer> getObservable() {
return Observable.range(0, 100);
}
@Override
protected void onDestroy() {
super.onDestroy();
// 如果退出程序，就清除后台任务
mCompositeDisposable.clear();
}
}
代码输出：
05-15 17:15:49.664 29872-29872/zhangphil.app D/MainActivity: #####开始#####
05-15 17:15:49.664 29872-29872/zhangphil.app D/MainActivity数据: 0
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####结束#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####开始#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity数据: 10
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####结束#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####开始#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity数据: 20
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####结束#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####开始#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity数据: 30
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####结束#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####开始#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity数据: 40
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####结束#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####开始#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity数据: 50
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####结束#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####开始#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity数据: 60
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####结束#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####开始#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity数据: 70
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####结束#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####开始#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity数据: 80
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####结束#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####开始#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity数据: 90
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: #####结束#####
05-15 17:15:49.665 29872-29872/zhangphil.app D/MainActivity: onComplete
微信关注我们
转载内容版权归作者及来源网站所有！
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。
为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。
Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。
WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。
扫码在手机上查看文章
扫描二维码，手机阅读更方便
有任何问题或合作意向欢迎联系我们
Email: 99873273@qq.com
QQ: 99873273