RxAndroid学习笔记4（操作符-转换）

1. buffer

• buffer(int):将源Observable每n个作为一个list发射
  
  注意：
  • 最后发射的list的数量可能少于n
  • 当源Observable触发onError()时，buffer会立即执行onError()

• buffer(int,int)
  buffer(n,m):每次发射n个数据，每隔m个数据忽略

  
  
• buffer(Func0)
• buffer(Observable)
  buffer(Observable,int)
• buffer(Observable,Func1)
• buffer(long,TimeUnit)
  buffer(long,TimeUnit,Scheduler)
• buffer(long,TimeUnit,int)
  buffer(long,TimeUnit,int,Scheduler)
• buffer(long,long,TimeUnit)
  buffer(long,long,TimeUnit,Scheduler)

2. flatMap
   flatMap(Func1)：Func1将一个源Observable转换成多个Observable，并返回一个Observable，flatMap将返回的结果融合成自己的序列进行发射。
   注意：顺序可能会乱，如果需要保证顺序可以用ConcatMap
   flatMap(Func1,int)：第二个参数会限制观察者的最大数量，当达到最大限制时，若有订阅者订阅，会等待其他的观察者结束
   注意：当源Observable触发onError()时，会立即执行onError()
   

   

3. GroupBy
   groupBy(Func1)
   groupBy(Func1,Func1)
   将数据转换成Observables,每一个Observable发射一个子序列

   
   

4. Map
   map(Func1)：将源数据通过func1转化后发射其结果

   
   

5. scan

• scan(Func2)

  
  
  

  示例代码：

Observable.just(1, 2, 3, 4, 5)
    .scan(new Func2<Integer, Integer, Integer>() {
        @Override
        public Integer call(Integer sum, Integer item) {
            return sum + item;
        }
    }).subscribe(new Subscriber<Integer>() {
        @Override
        public void onNext(Integer item) {
            System.out.println("Next: " + item);
        }

        @Override
        public void onError(Throwable error) {
            System.err.println("Error: " + error.getMessage());
        }

        @Override
        public void onCompleted() {
            System.out.println("Sequence complete.");
        }
    });

• scan(R,Func2):提供第一次调用的数据R

6. window

• window(closingSelector)

  
  

• window(windowOpenings, closingSelector)

  
  

• window(count)

  
  

• window(count, skip)