Rx是异步响应式编程的意思,本质是观察者模式,以观察者和订阅者的异步响应式编程。
本文主要介绍了关于RxJava 2. x新特性的相关资料,下面话不多说,来看看详细的介绍吧。
Flowable.range (0, 10)
.subscribe(新的Subscriber () {
订阅子;//当订阅后,会首先调用这个方法,其实就相当于onStart (),//传入的订阅年代参数可以用于请求数据或者取消订阅
@Override
公共空间>
onsubscribe开始
onNext——→0
onNext——→1
onNext——→2
…
onNext——→10
onComplete
onsubscribe 之前结束
根据上面的代码的结果输出中可以看的到,当我们调用<代码> subscription.request (n) 方法的时候,不等<代码> onSubscribe() 中后面的代码执行,就会立刻执行到onNext方法,因此,如果你在onNext方法中使用到需要初始化的类时,应当尽量在<代码> subscription.request (n) 这个方法调用之前做好初始化的工作,
<强>另外一种创建方法
可流动的。新建(FlowableOnSubscribe () {
@Override
公共空间订阅(FlowableEmitter{e)抛出异常
e.onNext (1);
e.onNext (2);
e.onNext (3);
e.onNext (4);
e.onComplete ();
}
}//需要指定背压策略
, BackpressureStrategy.BUFFER);
<强>其他观察者模式
<李>单/SingleObserver李
<李>可完备化的/CompletableObserver李
<李>也许/MaybeObserver
李
以上三种类似,比较适合发送单个数据,并不适合发送大量数据。
//判断是否登陆
Maybe.just (isLogin ())//可能涉及到IO操作,放在子线程
.subscribeOn (Schedulers.newThread ())//取回结果传到主线程
.observeOn (AndroidSchedulers.mainThread ())
.subscribe(新的MaybeObserver () {
@Override
公共空间alt=" RxJava 2. x新特性总结整理">
以上就是关于RxJava 2. x新特性的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对的支持。
