深入浅出RxJava

Posted 2020-08-13

深入浅出RxJava（一：基础篇）

深入浅出RxJava(二：操作符)

深入浅出RxJava三--响应式的好处

深入浅出RxJava四-在Android中使用响应式编程

 

RxJava 到底是什么?

一个词：异步。

RxJava 好在哪?

换句话说，『同样是做异步，为什么人们用它，而不用现成的 AsyncTask / Handler / XXX / ... ？』

一个词：简洁。

RxJava 的优势也是简洁，但它的简洁的与众不同之处在于，随着程序逻辑变得越来越复杂，它依然能够保持简洁。

 

 (一)基本使用

1, 创建一个Observable对象，直接调用Observable.create即可

[java] view plain copy

 

1. Observable<String> myObservable = Observable.create(  
2.     new Observable.OnSubscribe<String>() {  
3.         @Override  
4.         public void call(Subscriber<? super String> sub) {  
5.             sub.onNext("Hello, world!");  
6.             sub.onCompleted();  
7.         }  
8.     }  
9. );  

这里定义的Observable对象仅仅发出一个Hello World字符串，然后就结束了。

 2, 创建一个Subscriber来处理Observable对象发出的字符串。

[java] view plain copy

 

1. Subscriber<String> mySubscriber = new Subscriber<String>() {  
2.     @Override  
3.     public void onNext(String s) { System.out.println(s); }  
4.   
5.     @Override  
6.     public void onCompleted() { }  
7.   
8.     @Override  
9.     public void onError(Throwable e) { }  
10. };  

 这里subscriber仅仅就是打印observable发出的字符串。

 

3, 通过subscribe函数就可以将我们定义的myObservable对象和mySubscriber对象关联起来，这样就完成了subscriber对observable的订阅。

myObservable.subscribe(mySubscriber);  

一旦mySubscriber订阅了myObservable，myObservable就会调用mySubscriber对象的onNext和onComplete方法，mySubscriber就会打印出Hello World！

 

(二)操作符

map: 映射, 变换, 用来把把一个事件转换为另一个事件的。

flatMap: 平滑映射, 接收一个Observable的输出作为输入，同时输出另外一个Observable。

filter: 过滤, 输出和输入相同的元素，并且会过滤掉那些不满足检查条件的。

doOnNext(): 在每次输出一个元素之前做一些额外的事情

take: 输出最多指定数量的结果。

...更多操作符请查看官方api文档.

 

 

 

 

 

 

 

 

 

 

 

 

深入原理:给 Android 开发者的 RxJava 详解