1.過濾操作
filter(?) — 過濾數(shù)據(jù)
Observable.just(1,2,3,4,5,6)??????? .filter(newFunc1() {@OverridepublicBooleancall(Integer integer){//從數(shù)組中数苫，篩選偶數(shù)returninteger %2==0;??????????? }??????? }).subscribe(newAction1() {@Overridepublicvoidcall(Integer i){??????????????? Log.d("RxJava", String.valueOf(i));??????? }});
結(jié)果：
11-06 03:42:04.747 4213-4213/? D/RxJava: 211-06 03:42:04.747 4213-4213/? D/RxJava: 411-06 03:42:04.747 4213-4213/? D/RxJava: 6
takeLast( ) — 只發(fā)射最后的N項(xiàng)數(shù)據(jù)
Observable.just(1,2,3,4,5,6)??????? .takeLast(3)//取最后3項(xiàng)數(shù)據(jù).subscribe(newAction1() {@Overridepublicvoidcall(Integer i){??????????????? Log.d("RxJava", String.valueOf(i));??????????? }??????? });
結(jié)果：
11-06 03:44:18.307 6379-6379/keye.com.rxjavaobserver D/RxJava: 411-06 03:44:18.307 6379-6379/keye.com.rxjavaobserver D/RxJava: 511-06 03:44:18.307 6379-6379/keye.com.rxjavaobserver D/RxJava: 6
last( ) — 只發(fā)射最后的一項(xiàng)數(shù)據(jù)
Observable.just(1,2,3,4,5,6)??????? .last()??????? .subscribe(newAction1() {@Overridepublicvoidcall(Integer i){??????????????? Log.d("RxJava", String.valueOf(i));??????????? }??????? });
結(jié)果：
11-06 03:49:46.710 6582-6582/? D/RxJava: 6
skip( ) — 跳過開始的N項(xiàng)數(shù)據(jù)
Observable.just(1,2,3,4,5,6)??????? .skip(3)??????? .subscribe(newAction1() {@Overridepublicvoidcall(Integer i){??????????????? Log.d("RxJava", String.valueOf(i));??????????? }??????? });
結(jié)果：
11-06 03:49:46.710 6582-6582/? D/RxJava: 411-06 03:49:46.710 6582-6582/? D/RxJava: 511-06 03:49:46.710 6582-6582/? D/RxJava: 6
take( ) — 只發(fā)射開始的N項(xiàng)數(shù)據(jù)
Observable.just(1,2,3,4,5,6)??????? .take(3)??????? .subscribe(i -> {??????????? Log.d("RxJava",String.valueOf(i));??????? });
結(jié)果：
11-06 03:49:46.710 6582-6582/? D/RxJava: 111-06 03:49:46.710 6582-6582/? D/RxJava: 211-06 03:49:46.710 6582-6582/? D/RxJava: 3
first( ) and takeFirst( ) — 只發(fā)射第一項(xiàng)數(shù)據(jù)，或者滿足某種條件的第一項(xiàng)數(shù)據(jù)
Observable.just(1,2,3,4,5,6)??????? .first()??????? .subscribe(i -> {??????????? Log.d("RxJava",String.valueOf(i));??????? });
結(jié)果：
11-06 03:49:46.710 6582-6582/? D/RxJava: 1
elementAt( ) — 發(fā)射第N項(xiàng)數(shù)據(jù)
Observable.just(1,2,3,4,5,6)??????? .elementAt(3)??????? .subscribe(i -> {??????????? Log.d("RxJava",String.valueOf(i));??????? });
結(jié)果：
11-06 03:49:46.710 6582-6582/? D/RxJava: 4
sample( ) or throttleLast( ) — 定期發(fā)射Observable最近的數(shù)據(jù)
Observable.interval(1,TimeUnit.SECONDS)??????? .sample(4, TimeUnit.SECONDS)??????? .subscribe(i -> {??????????? Log.d("RxJava",String.valueOf(i));??????? });
結(jié)果：interval()每隔一秒發(fā)送整數(shù)序列鳄抒，sample()每隔4秒撤防，獲取Observable的數(shù)據(jù)，結(jié)果如下：
-16618/keye.com.rxjavaobserver D/RxJava: 3-16618/keye.com.rxjavaobserver D/RxJava: 6-16618/keye.com.rxjavaobserver D/RxJava: 10-16618/keye.com.rxjavaobserver D/RxJava: 14-16618/keye.com.rxjavaobserver D/RxJava: 18-16618/keye.com.rxjavaobserver D/RxJava: 22
debounce( ) — 只有當(dāng)Observable在指定的時間后還沒有發(fā)射數(shù)據(jù)時咆瘟，才發(fā)射一個數(shù)據(jù)
Observable.create(newObservable.OnSubscribe() {@Overridepublicvoidcall(Subscriber subscriber){try{for(inti =1; i <10; i++) {??????????????? subscriber.onNext(i);??????????????? Thread.sleep(i *1000);//每次發(fā)送嚼隘，延遲i*1秒}??????????? subscriber.onCompleted();??????? }catch(Exception e) {??????????? subscriber.onError(e);??????? }??? }})??????? .subscribeOn(Schedulers.newThread())??????? .debounce(3000, TimeUnit.MILLISECONDS)//3秒沒有數(shù)據(jù)，則發(fā)送.subscribe(newAction1() {@Overridepublicvoidcall(Integer integer){??????????????? Log.d("RxJava", String.valueOf(integer));??????????? }??????? });
結(jié)果：前3個數(shù)延遲短袒餐，沒有觸發(fā)debounce()操作符飞蛹，第4個數(shù)延遲3秒，debounce()生效
30534-30550/keye.com.rxjavaobserver D/RxJava: 430534-30550/keye.com.rxjavaobserver D/RxJava: 530534-30550/keye.com.rxjavaobserver D/RxJava: 630534-30550/keye.com.rxjavaobserver D/RxJava: 730534-30550/keye.com.rxjavaobserver D/RxJava: 8
distinct( ) — 過濾掉重復(fù)數(shù)據(jù)
Observable.just(1,2,1,4,1,6)??????? .distinct()??????? .subscribe(i -> {??????????? Log.d("RxJava",String.valueOf(i));??????? });
結(jié)果：
11-06 04:38:49.987 19504-19504/keye.com.rxjavaobserver D/RxJava: 111-06 04:38:49.987 19504-19504/keye.com.rxjavaobserver D/RxJava: 211-06 04:38:49.987 19504-19504/keye.com.rxjavaobserver D/RxJava: 411-06 04:38:49.988 19504-19504/keye.com.rxjavaobserver D/RxJava: 6
ofType( ) — 只發(fā)射指定類型的數(shù)據(jù)
Observable.just(1,"2",3,"4",5,6)??????? .ofType(Integer.class)??????? .subscribe(i -> {??????????? Log.d("RxJava", String.valueOf(i));??????? });
結(jié)果：
11-06 04:44:28.321 25785-25785/keye.com.rxjavaobserver D/RxJava: 1
11-06 04:44:28.321 25785-25785/keye.com.rxjavaobserver D/RxJava: 3
11-06 04:44:28.321 25785-25785/keye.com.rxjavaobserver D/RxJava: 5
11-06 04:44:28.321 25785-25785/keye.com.rxjavaobserver D/RxJava: 6
