編輯：關於Android編程
1、merge操作符，合並觀察對象
Observable observable1 = Observable.just(6,7,8) ;
Observable observable2 = Observable.just("a","b","c") ;
//合並數據 先發送observable2的全部數據，然後發送 observable1的全部數據
Observable observable = Observable.merge( observable2 , observable1 ) ;
observable.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e("call==",""+o);
}
});
2、zip 操作符，合並多個觀察對象的數據。並且允許 Func2（）函數重新發送合並後的數據
Observable observable1 = Observable.just("6","7","8") ;
Observable observable2 = Observable.just("a","b","c") ;
Observable observable3 = Observable.zip(observable1, observable2, new Func2() {
@Override
public String call(String s1 , String s2 ) {
return s1 + s2 ;
}
}) ;
observable3.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "zip-- ",""+ o );
}
}) ;
3 scan累加器操作符的使用
Observable observable = Observable.just( 1 , 2 , 3 , 4 , 5 ) ;
observable.scan(new Func2() {
@Override
public Integer call(Integer o, Integer o2) {
return o + o2 ;
}
}).subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "scan-- ",""+o );
}
});
4 filter 過濾操作符的使用
Observable observable = Observable.just( 1 , 2 , 3 , 4 , 5 , 6 , 7 ) ;
observable.filter(new Func1() {
@Override
public Boolean call(Integer o) {
//數據大於4的時候才會被發送
return o > 4 ;
}
}).subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "filter-- ",""+ o );
}
});
5 消息數量過濾操作符的使用
* take ：取前n個數據
* takeLast：取後n個數據
* first 只發送第一個數據
* last 只發送最後一個數據
* skip() 跳過前n個數據發送後面的數據
* skipLast() 跳過最後n個數據，發送前面的數據
//take 發送前3個數據
Observable observable = Observable.just( 1 , 2 , 3 , 4 , 5 , 6 , 7 ) ;
observable.take( 3 )
.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "take-- ","" +o );
}
}) ;
//takeLast 發送最後三個數據
Observable observable2 = Observable.just( 1 , 2 , 3 , 4 , 5 , 6 , 7 ) ;
observable2.takeLast( 3 )
.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "takeLast-- ","" +o );
}
}) ;
//first 只發送第一個數據
Observable observable3 = Observable.just( 1 , 2 , 3 , 4 , 5 , 6 , 7 ) ;
observable3.first()
.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "first-- ","" +o );
}
}) ;
//last 只發送最後一個數據
Observable observable4 = Observable.just( 1 , 2 , 3 , 4 , 5 , 6 , 7 ) ;
observable4.last()
.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "last-- ","" +o );
}
}) ;
//skip() 跳過前2個數據發送後面的數據
Observable observable5 = Observable.just( 1 , 2 , 3 , 4 , 5 , 6 , 7 ) ;
observable5.skip( 2 )
.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "skip-- ","" +o );
}
}) ;
//skipLast() 跳過最後兩個數據，發送前面的數據
Observable observable6 = Observable.just( 1 , 2 , 3 , 4 , 5 , 6 , 7 ) ;
observable6.skipLast( 2 )
.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "skipLast-- ","" +o );
}
}) ;
6 elementAt 、elementAtOrDefault
//elementAt() 發送數據序列中第n個數據 ，序列號從0開始
//如果該序號大於數據序列中的最大序列號，則會拋出異常，程序崩潰
//所以在用elementAt操作符的時候，要注意判斷發送的數據序列號是否越界
int s = 6;
List list = new ArrayList<>();
for (int i = 0; i < 7; i++) {
list.add(i);
}
if(s >= list.size()){
Log.e("elementAt","角標越界了");
}else {
Observable observable7 = Observable.from(list);
observable7.elementAt(s)
.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e("elementAt-- ", "" + o);
}
});
}
//elementAtOrDefault( int n , Object default ) 發送數據序列中第n個數據 ，序列號從0開始。
//如果序列中沒有該序列號，則發送默認值
Observable observable9 = Observable.just( 1 , 2 , 3 , 4 , 5 ) ;
observable9.elementAtOrDefault( 8 , 666 )
.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "elementAtOrDefault-- ",""+ o );
}
}) ;
7 startWith() 插入數據
//插入普通數據
//startWith 數據序列的開頭插入一條指定的項 , 最多插入9條數據
Observable observable = Observable.just( "aa" , "bb" , "cc" ) ;
observable
.startWith( "dd" , "ee" )
.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "startWith-- ",""+ o );
}
}) ;
//插入Observable對象
List list = new ArrayList<>() ;
list.add( "ff" ) ;
list.add( "gg" ) ;
observable.startWith( Observable.from( list ))
.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "startWith2 -- ",""+ o );
}
}) ;
8 delay操作符，延遲數據發送
Observableobservable = Observable.just( "1" , "2" , "3" , "4" , "5" , "6" , "7" , "8" ) ; //延遲數據發射的時間，僅僅延時一次，也就是發射第一個數據前延時。發射後面的數據不延時 observable.delay( 3 , TimeUnit.SECONDS ) //延遲3秒鐘 .subscribe(new Action1() { @Override public void call(Object o) { Log.e("delay-- ",""+ o); } }) ;
9 Timer 延時操作符的使用
//5秒後輸出 hello world , 然後顯示一張圖片
Observable.timer( 5 , TimeUnit.SECONDS )
.observeOn(AndroidSchedulers.mainThread() )
.subscribe(new Action1() {
@Override
public void call(Long aLong) {
Log.e( "timer--hello world ",""+aLong );
}
}) ;
delay 、timer 總結：
相同點：delay 、 timer 都是延時操作符。
不同點：delay 延時一次，延時完成後，可以連續發射多個數據。timer延時一次，延時完成後，只發射一次數據。
10 interval 輪詢操作符，循環發送數據，數據從0開始遞增
//參數一：延遲時間 參數二：間隔時間 參數三：時間顆粒度
Observable observable = Observable.interval(3000, 1000, TimeUnit.MILLISECONDS) ;
Subscription subscription = observable.subscribe(new Action1() {
@Override
public void call(Object o) {
Log.e( "interval- ","" + o );
}
}) ;
11 doOnNext() 操作符，在每次 OnNext() 方法被調用前執行
使用場景：從網絡請求數據，在數據被展示前，緩存到本地
Observable observable = Observable.just( "1" , "2" , "3" , "4" ) ;
observable.doOnNext(new Action1() {
@Override
public void call(Object o) {
Log.e( "doOnNext--緩存數據",""+ o );
}
}).subscribe(new Observer() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Object o) {
Log.e( "onNext--",""+ o );
}
}) ;
12 Buffer 操作符
Buffer( int n ) 把n個數據打成一個list包，然後再次發送。
Buffer( int n , int skip) 把n個數據打成一個list包，然後跳過第skip個數據。
