android rxjava 过滤,RxJava 过滤操作符 sample
sample操作符是定期扫描源Observable产生的结果，在指定的间隔周期内进行采样例子1：每2s扫描一次Observable.interval(1, TimeUnit.SECONDS).sample(2, TimeUnit.SECONDS).subscribe(new Observer() {@Overridepublic void onCompleted() {LogUtils.d("--
sample操作符是定期扫描源Observable产生的结果，在指定的间隔周期内进行采样
例子1：每2s扫描一次
Observable.interval(1, TimeUnit.SECONDS).sample(2, TimeUnit.SECONDS).subscribe(new Observer() {
@Override
public void onCompleted() {
LogUtils.d("-------->onCompleted()");
}
@Override
public void onError(Throwable e) {
LogUtils.d("-------->onError()" + e);
}
@Override
public void onNext(Long aLong) {
LogUtils.d("-------->onNext()" + aLong);
}
});结果:
03-02 09:36:08.722 8623-8768/com.rxandroid.test1 D/----->: -------->onNext()0
03-02 09:36:10.722 8623-8768/com.rxandroid.test1 D/----->: -------->onNext()2
03-02 09:36:12.722 8623-8768/com.rxandroid.test1 D/----->: -------->onNext()4
03-02 09:36:14.722 8623-8768/com.rxandroid.test1 D/----->: -------->onNext()6
.....
注意这里会默认开启一个新线程，我们也可以指定线程
Observable.interval(1, TimeUnit.SECONDS).sample(2, TimeUnit.SECONDS, Schedulers.newThread()).subscribe(new Observer() {
@Override
public void onCompleted() {
LogUtils.d("-------->onCompleted()");
}
@Override
public void onError(Throwable e) {
LogUtils.d("-------->onError()" + e);
}
@Override
public void onNext(Long aLong) {
LogUtils.d("-------->onNext()" + aLong + " thread:" + Thread.currentThread().getName());
}
});结果:
03-02 09:43:25.582 15427-15698/com.rxandroid.test1 D/----->: -------->onNext()0 thread:RxNewThreadScheduler-2
....
华为开发者空间，是为全球开发者打造的专属开发空间，汇聚了华为优质开发资源及工具，致力于让每一位开发者拥有一台云主机，基于华为根生态开发、创新。
更多推荐
0
0- 0
已为社区贡献3条内容
所有评论(0)