RxJava操作符实践:3_过滤操作之4_skip

一、描述

抑制Observable发射的前N项数据。

使用Skip操作符,你可以忽略Observable发射的前N项数据,只保留之后的数据。

skip的这个变体默认不在任何特定的调度器上执行。

二、示意图

skip

三、示例代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
Observable.just(1, 2, 3, 4, 5, 6)
.skip(3)
.subscribe(new Subscriber<Integer>() {
@Override
public void onCompleted() {
System.out.println("onCompleted.");
}

@Override
public void onError(Throwable e) {
System.out.println("onError: " + e.getMessage());
}

@Override
public void onNext(Integer integer) {
System.out.println("onNext: " + integer);
}
});

四、运行结果

1
2
3
4
onNext: 4
onNext: 5
onNext: 6
onCompleted.

项目代码已上传到Github:https://github.com/SherlockShi/RxJavaBestPractise

五、更多

skip操作符还有以下变体:

  • skip(long,TimeUnit)
  • skip(long,TimeUnit,Scheduler)

详情可查阅下面的参考资料。

六、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS:欢迎关注 SherlockShi 个人博客

感谢你的支持,让我继续努力分享有用的技术和知识点!