常用创建操作符
create、just、from、interval、range、repeat等
实例与功能介绍
1. create操作符
代码实例
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("杨");
subscriber.onNext("月");
subscriber.onCompleted();
}
});
结果
结果: 杨
结果: 月
结束
2. just操作符
代码实例
Observable observable = Observable.just("影","眉");
结果
结果: 影
结果: 眉
结束
3. from操作符
代码实例
String[] words = {"枫","儿"};
Observable observable = Observable.from(words);
结果
结果: 枫
结果: 儿
结束
4. interval操作符
代码实例
Observable observable = Observable.interval(1, TimeUnit.SECONDS);
功能:按固定时间间隔发送整数序列
5. range操作符
代码实例
Observable observable = Observable.range(0, 5);
结果
结果: 0
结果: 1
结果: 2
结果: 3
结果: 4
结束
功能:发射指定范围内的整数序列
6. repeat操作符
代码实例
Observable observable = Observable.range(0, 4).repeat(2);
功能:重复n此发射特定数据
结果
结果: 0
结果: 1
结果: 2
结果: 3
结果: 0
结果: 1
结果: 2
结果: 3
结束