RxJava2 / RxAndroid2操作符skip
RxJava2 / RxAndroid2操作符skip
顾名思义,skip跳过,例如:
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.observers.DisposableObserver; import io.reactivex.schedulers.Schedulers; public class MainActivity extends AppCompatActivity { private final String TAG = getClass().getSimpleName(); private CompositeDisposable mCompositeDisposable = null; @Override public void onCreate(@Nullable Bundle savedInstanceState) { super.onCreate(savedInstanceState); mCompositeDisposable = new CompositeDisposable(); 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() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .skip(5) .subscribeWith(disposableObserver)); } private Observable<Integer> getObservable() { return Observable.range(0, 10); } @Override protected void onDestroy() { super.onDestroy(); // 如果退出程序,就清除后台任务 mCompositeDisposable.clear(); } }
代码运行结果:
05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: #####开始##### 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity数据: 5 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: #####结束##### 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: #####开始##### 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity数据: 6 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: #####结束##### 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: #####开始##### 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity数据: 7 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: #####结束##### 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: #####开始##### 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity数据: 8 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: #####结束##### 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: #####开始##### 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity数据: 9 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: #####结束##### 05-16 14:22:09.606 16806-16806/zhangphil.app D/MainActivity: onComplete
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
RxAndroid2 / RxJava2简单的CompletableObserver
RxAndroid2 / RxJava2简单的CompletableObserver CompletableObserver简单的用法跟踪一个任务的结束,不处理复杂的数据传导,例如: package zhangphil.app; import android.os.Bundle; import android.support.annotation.Nullable; import android.support.v7.app.AppCompatActivity; import android.util.Log; import java.util.concurrent.Callable; import io.reactivex.Completable; import io.reactivex.CompletableObserver; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.disposables.Disposable; import io.reactivex.schedul...
- 下一篇
Android 获取系统语言(兼容7.0)
转载连接:http://likfe.com/2017/05/10/android-sys-language/ 前言 获取系统当前语言是一个比较常用的功能,在 Android 7.0 系统上旧函数获取到的当前系统语言并不正确,或者说从 Android 7.0 起,Android 系统语言的规则变了。 下面是未适配 Android 7.0 的代码: //获取 Locale 的方式有二 //方式一 Locale locale = getResources().getConfiguration().locale; //方式二 Locale locale = Locale.getDefault(); //获取当前系统语言 locale.getLanguage(); 由于仅仅根据 getLanguage() 无法全面的了解当前的系统语言信息,比如简体中文和繁体中文的 Language 都是 zh,所以还需要 getCountry() 方法获取地区信息,我们就能得到 zh-CN 和 zh-HK/zh-TW 。 总结一下就是: //获取 Locale 的方式有二 //方式一 Locale locale...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- Mario游戏-低调大师作品
- Eclipse初始化配置,告别卡顿、闪退、编译时间过长
- SpringBoot2整合Thymeleaf,官方推荐html解决方案
- CentOS8安装MyCat,轻松搞定数据库的读写分离、垂直分库、水平分库
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,CentOS8安装Elasticsearch6.8.6
- CentOS8安装Docker,最新的服务器搭配容器使用
- CentOS7,8上快速安装Gitea,搭建Git服务器
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题