Rxjava练习册(二)

准备工作 //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功能相似，取最后一个元素，取不到返回设置的元素