响应式编程Rxjava2

1.需要的依赖

implementation "io.reactivex.rxjava2:rxjava:2.1.12"

implementation "io.reactivex.rxjava2:rxandroid:2.0.2"

 

2.基本使用

3.just fromArray的使用

4.interval和timer的使用

5.range的使用

6.repeat方法的使用

7.map的使用

8.flatMap的使用

flatMap() 的原理是这样的：1. 使用传入的事件对象创建一个 Observable 对象；2. 并不发送这个 Observable, 而是将它**，于是它开始发送事件；3. 每一个创建出来的 Observable 发送的事件，都被汇入同一个 Observable ，而这个 Observable 负责将这些事件统一交给 Subscriber 的回调方法。这三个步骤，把事件拆成了两级，通过一组新创建的 Observable 将初始的对象『铺平』之后通过统一路径分发了下去。而这个『铺平』就是 flatMap() 所谓的 flat。

 

9.concatMap的使用

10.flatMapIterable的使用

11.buffer的使用

12.groupBy的使用

13.filter的使用

14.elementAt的使用

15.distinct的使用

16.skip  take  skipLast  takeLast的使用

17.throttleFirst的使用

18.throttleWithTimeOut的使用

19.startWith的使用

20.merge  concat  zip combineLast的使用

21.

22.subscribeOn  observerOn的使用

23.onErrorReturn  onErrorResumeNext  onExceptionResumeNext

24.retry的使用

25.all  contains  isEmpty的使用

26.defaultIfEmpty的使用

27.toList  toSortList的使用

28.背压的使用

demo: https://github.com/yunzheyue/rxtest