1.變換操作
scan(?) — 對Observable發(fā)射的每一項數(shù)據(jù)應(yīng)用一個函數(shù)，然后按順序依次發(fā)射每一個值
Observable.just(1,2,3)??????? .scan(newFunc2() {@OverridepublicIntegercall(Integer integer, Integer integer2){//自定義函數(shù)returninteger + integer2;??????????? }??????? })??????? .subscribe(newAction1() {@Overridepublicvoidcall(Integer integer){??????????????? Log.d("RxJava", String.valueOf(integer));??????????? }??????? });
結(jié)果：將自定義函數(shù)應(yīng)用于數(shù)據(jù)序列，并將這個函數(shù)的結(jié)果作為函數(shù)下一次的參數(shù)1使用，1+0=1，1+2=3 ，3+3=6
11-06 02:54:43.040 25433-25433/keye.com.rxjavaobserver D/RxJava: 111-06 02:54:43.040 25433-25433/keye.com.rxjavaobserver D/RxJava: 311-06 02:54:43.040 25433-25433/keye.com.rxjavaobserver D/RxJava: 6
groupBy(?) — 將Observable分拆為Observable集合，將原始Observable發(fā)射的數(shù)據(jù)按Key分組，每一個Observable發(fā)射一組不同的數(shù)據(jù)
Observable.just(1,2,3,4)??????? .groupBy(newFunc1() {@OverridepublicIntegercall(Integer integer){//這里返回的結(jié)果為keyreturninteger +1;??????????? }??????? })??????? .subscribe(newAction1>() {@Overridepublicvoidcall(GroupedObservable groupedObservable){??????????????? groupedObservable.subscribe(newAction1() {@Overridepublicvoidcall(Integer integer){??????????????????????? Log.d("RxJava","key:"+ groupedObservable.getKey() +",value:"+ integer);??????????????????? }??????????????? });??????????? }??????? });
結(jié)果：在第一個func1函數(shù)中，設(shè)置key，最后生成一個Observable集合，并把每一個groupedObservable，并依次發(fā)射出去
3162-3162/keye.com.rxjavaobserver D/RxJava: key:2,value:13162-3162/keye.com.rxjavaobserver D/RxJava: key:3,value:23162-3162/keye.com.rxjavaobserver D/RxJava: key:4,value:33162-3162/keye.com.rxjavaobserver D/RxJava: key:5,value:4
buffer(?) — 它定期從Observable收集數(shù)據(jù)到一個集合，然后把這些數(shù)據(jù)集合打包發(fā)射，而不是一次發(fā)射一個
Observable.just(1,2,3,4,5,6,7)????????? .buffer(2,1)????????? .subscribe(newAction1>() {@Overridepublicvoidcall(List integers){??????????????? Log.d("RxJava", integers +"");????????????? }});
結(jié)果：buffer()有兩個參數(shù)count和skip，count指定List的大小，skip指定每次發(fā)射一個List需要跳過幾個數(shù)；buffer(2,?1)：每組2個數(shù)，每次跳過1個數(shù)，結(jié)果如下：
keye.com.rxjavaobserver D/RxJava: [1, 2]keye.com.rxjavaobserver D/RxJava: [4, 5]keye.com.rxjavaobserver D/RxJava: [7]
window(?) — 定期將來自O(shè)bservable的數(shù)據(jù)分拆成一些Observable窗口，然后發(fā)射這些窗口，而不是每次發(fā)射一項
Observable.just(1,2,3,4,5,6,7)????????? .window(2,2)????????? .subscribe(newAction1>() {@Overridepublicvoidcall(Observable observable){????????????????? Log.d("RxJava","window");????????????????? observable.subscribe(newAction1() {@Overridepublicvoidcall(Integer integer){????????????????????????? Log.d("RxJava", integer +"");????????????????????? }????????????????? });????????????? }});
結(jié)果：window()操作符和buffer()類似，都是緩存一段數(shù)據(jù)集合，再打包發(fā)射出去
11-0603:30:29.19825883-25883/? D/RxJava:window11-0603:30:29.19825883-25883/? D/RxJava:111-0603:30:29.19825883-25883/? D/RxJava:211-0603:30:29.19825883-25883/? D/RxJava:window11-0603:30:29.19825883-25883/? D/RxJava:311-0603:30:29.19825883-25883/? D/RxJava:411-0603:30:29.19825883-25883/? D/RxJava:window11-0603:30:29.19825883-25883/? D/RxJava:511-0603:30:29.19925883-25883/? D/RxJava:611-0603:30:29.19925883-25883/? D/RxJava:window11-0603:30:29.19925883-25883/? D/RxJava:7
