准备工作 //www.greatytc.com/p/1ac62d93b962
练习一 //www.greatytc.com/p/6483b5babb45
这一章练习一些操作符：
take 获取前面的序列
takeLast 获取后面的序列
repeat 重复
repeatWhen 这个没有理解等理解了在写例子
empty 一个空序列
first 获取第一个序列
last 获取最后一个序列
firstOrDefault 获取第一个如果为空获取设置的
lastOrDefault 获取最后一刻如果为空返回设置的
take:
static void take(){
Integer arr[] = {1,2,3,4 };
Observable.from(arr).take(2).subscribe(integerObserver);
}
static void take(int num) {
Integer arr[] = {1,2,3,4 };
Observable.from(arr).take(num).subscribe(integerObserver);
}
- 从一个序列中获取前面的几个
-
如果take的参数大于集合的大小，将会执行完集合（不报错）
屏幕快照 2016-01-23 下午4.55.26.png
5707123A-B6EA-4D2B-A316-62B731E501AC.png
takeLast:
static void takeLast(int num){
Integer arr[] = {1,2,3,4 };
Observable.from(arr).takeLast(num).subscribe(integerObserver);
}
- take与takeLast功能上差不多，takeLast是取后面的序列
repeat:
static void repeat(){
Observable.just(1).repeat(2).subscribe(integerObserver);
}
static void repeat2(){
Observable.just(2).repeat().subscribe(integerObserver);
}
static void repeat3(){
Observable.just(3).repeat().take(4).subscribe(integerObserver);
}
- repeat中的参数就是重复的次数
-
repeat中不写参数会无限的执行下去
运行结果是repeat()
屏幕快照 2016-01-23 下午4.49.03.png
first:
static void first(){
Integer arr[] = {1,2,3,4 };
//这里会获取集合的第一个元素
Observable.from(arr).first().subscribe(integerObserver);
}
static Observer<Object> objectObserver = new Observer<Object>() {
@Override
public void onCompleted() {
System.out.println("onCompleted");
}
@Override
public void onError(Throwable e) {
System.out.println("onError");
}
@Override
public void onNext(Object o) {
System.out.println(o);
}};
static void first2(){
Observable.empty().first().subscribe(objectObserver);
}
- first 会获取第一个元素，如果获取不到会调用Observer的onError方法
697F53C6-BAB4-497F-A115-16FFEB79748D.png
last:
static void last(){
Integer arr[] = {1,2,3,4 };
Observable.from(arr).last().subscribe(integerObserver);
}static void last2(){
Observable.empty().last().subscribe(objectObserver);
}
- last和first的功能相似，last是获取最后一个元素，获取不到调用Observer的onError方法
firstOrDefault:
static void firstOrDefault(){
Integer arr[] = {1,2,3,4 };
Observable.from(arr).firstOrDefault(9).subscribe(integerObserver);
}
static void firstOrDefault2(){
Observable.empty().firstOrDefault(9).subscribe(objectObserver);
}
- firstOrDefault与first的不同点就是当firstOrDefault获取不到第一个元素的时候会返回设置的元素
D380C235-092E-40B9-A46E-A31DF3E5F5E2.png
lastOrDefault:
static void lastOrDefault(){
Integer arr[] = {1,2,3,4 };
Observable.from(arr).lastOrDefault(9).subscribe(integerObserver);
}
static void lastOrDefault2(){
Observable.empty().lastOrDefault(9).subscribe(objectObserver);
}
- 与firstOrDefault功能相似，取最后一个元素，取不到返回设置的元素
