Rxjava2使用总结

2019-06-13 · 大约 800 个字 · 预计 4 分钟读完

Android · 框架

RxJava · 响应式编程 · 函数式编程

前言

Rxjava2 是 函数式编程 和 响应式编程 两种牛逼的思想结合的产物，也是在 Java 中这两种思想的一种实现。

函数响应式编程 (Functional Reactive Programming:FRP)：是一种通过一系列函数的组合调用来发射，转变，监听，响应数据流的编程范式。

在 Rxjava2 中提供了 5种 观察者模式来实现这种函数响应式编程思想。

ObservableSource/Observer

可通过 onNext 方法发送单条数据或者数据序列，通过 onComplete 发送完成通知或通过 onError 发送异常通知，不支持 背压策略。

抽象类 Observable 是接口 ObservableSource 下的一个抽象实现，我们可以通过 Observable 创建一个可观察对象发射数据流。

1
2
3
4
5
6
7
Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    public void subscribe(ObservableEmitter<String> emitter) throws Exception {
        emitter.onNext("Hello World");
        emitter.onComplete();
    }
});

调用 Observable.create 方法，创建一个可观察对象，并通过 onNext 发送一条数据 “Hello World”，然后通过 onComplete 发送完成通知。