前言
Rxjava2 是 函数式编程
和 响应式编程
两种牛逼的思想结合的产物,也是在 Java 中这两种思想的一种实现。
函数响应式编程 (Functional Reactive Programming:FRP):是一种通过一系列函数的组合调用来发射,转变,监听,响应数据流的编程范式。
在 Rxjava2 中提供了 5种
观察者模式来实现这种函数响应式编程思想。
ObservableSource/Observer
可通过 onNext
方法发送单条数据或者数据序列,通过 onComplete
发送完成通知或通过 onError
发送异常通知,不支持 背压策略
。
抽象类 Observable
是接口 ObservableSource
下的一个抽象实现,我们可以通过 Observable 创建一个可观察对象发射数据流。
|
|
调用 Observable.create
方法,创建一个可观察对象,并通过 onNext 发送一条数据 “Hello World”,然后通过 onComplete 发送完成通知。