RxJava操作符实践:4_结合操作之1_startWith

一、描述

在数据序列的开头插入一条指定的项。

如果你想要一个Observable在发射数据之前先发射一个指定的数据序列,可以使用StartWith操作符。(如果你想一个Observable发射的数据末尾追加一个数据序列可以使用Concat操作符。)

二、示意图

startWith

三、示例代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
Observable.just(1, 2, 3)
.startWith(9, 8)
.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
5
6
onNext: 9
onNext: 8
onNext: 1
onNext: 2
onNext: 3
onCompleted.

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

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS:欢迎关注 SherlockShi 个人博客

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