RxJava 2.x新特性总结整理的图文介绍

这篇文章主要介绍了RxJava 2.x新特性的相关资料，文中通过图文及示例代码介绍的非常详细，对大家具有一定的参考价值，需要的朋友们下面来一起看看吧。

什么是RxJava

Rx是异步响应式编程的意思，本质是观察者模式，以观察者和订阅者的异步响应式编程。

本文主要介绍了关于RxJava 2.x新特性的相关资料，下面话不多说，来看看详细的介绍吧。

背压的分离

Flowable/Subscriber

Flowable.range(0,10).subscribe(new Subscriber<Integer>() { Subscription sub; //当订阅后，会首先调用这个方法，其实就相当于onStart()， //传入的Subscription s参数可以用于请求数据或者取消订阅 @Override public void onSubscribe(Subscription s) { Log.w("TAG","onsubscribe start"); sub=s; sub.request(1); Log.w("TAG","onsubscribe end"); } @Override public void onNext(Integer o) { Log.w("TAG","onNext--->"+o); sub.request(1); } @Override public void one rror(Throwable t) { t.printStackTrace(); } @Override public void onComplete() { Log.w("TAG","onComplete"); }});

输出:

onsubscribe startonNext--->0onNext--->1onNext--->2...onNext--->10onCompleteonsubscribe end

根据上面的代码的结果输出中可以看到，当我们调用subscription.request(n)方法的时候，不等onSubscribe()中后面的代码执行，就会立刻执行到onNext方法，因此，如果你在onNext方法中使用到需要初始化的类时，应当尽量在subscription.request(n)这个方法调用之前做好初始化的工作;

另外一种创建方法

Flowable.create(new FlowableOnSubscribe<Integer>() {  @Override  public void subscribe(FlowableEmitter<Integer> e) throws Exception {  e.onNext(1);  e.onNext(2);  e.onNext(3);  e.onNext(4);  e.onComplete();  } } //需要指定背压策略 , BackpressureStrategy.BUFFER);

其他观察者模式

• Single/SingleObserver

• Completable/CompletableObserver

• Maybe/MaybeObserver

以上三种类似, 比较适合发送单个数据, 并不适合发送大量数据.

//判断是否登陆Maybe.just(isLogin()) //可能涉及到IO操作，放在子线程 .subscribeOn(Schedulers.newThread()) //取回结果传到主线程 .observeOn(AndroidSchedulers.mainThread()) .subscribe(new MaybeObserver<Boolean>() {  @Override  public voi<em style="color:transparent">本文来源gao.dai.ma.com搞@代*码#网</em>d onSubscribe(Disposable d) {  }  @Override  public void onSuccess(Boolean value) {  if(value){   ...  }else{   ...  }  }  @Override  public void one rror(Throwable e) {  }  @Override  public void onComplete() {  } });

实际上，这种观察者模式并不用于发送大量数据，而是发送单个数据，也就是说，当你只想要某个事件的结果（true or false)的时候，你可以用这种观察者模式

Action
Rx1.0———–Rx2.0

Action1——–Action

Action1——–Consumer

Action2——–BiConsumer

后面的Action都去掉了，只保留了ActionN

参考

总结

以上就是RxJava 2.x新特性总结整理的图文介绍的详细内容，更多请关注搞代码gaodaima其它相关文章！

喜欢 (0)赏

[搞代码]

分享 (0)