截止日前最新版2017-3-15:?
RxJava

compile ‘io.reactivex:rxjava:1.2.7’ compile ‘io.reactivex:rxandroid:1.2.1’

RxJava2

compile “io.reactivex.rxjava2:rxjava:2.0.7” compile “io.reactivex.rxjava2:rxandroid:2.0.1”

1:create操作改變?
Rxjava

CompositeSubscription compositeSubscription = new CompositeSubscription(); Observable<String> observable = Observable.create(new Observable.OnSubscribe<String>() {@Overridepublic void call(Subscriber<? super String> subscriber) {subscriber.onNext("1");subscriber.onNext("2");//e.onComplete();subscriber.onError(new NullPointerException());} }); Subscription subscribe = observable.subscribe(new Observer<String>() {@Overridepublic void onCompleted() {}@Overridepublic void onError(Throwable e) {}@Overridepublic void onNext(String s) {} });//取消訂閱 subscribe.unsubscribe(); //或者 compositeSubscription.add(subscribe); compositeSubscription.unsubscribe();

RxJava2

final CompositeDisposable compositeDisposable = new CompositeDisposable(); Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {@Overridepublic void subscribe(ObservableEmitter<String> e) throws Exception {e.onNext("1");e.onNext("2");//e.onComplete();e.onError(new NullPointerException());} });//subscribe方法返回void類型 observable.subscribe(new Observer<String>() {@Overridepublic void onSubscribe(Disposable d) {compositeDisposable.add(d);}@Overridepublic void onNext(String s) {}@Overridepublic void onError(Throwable e) {}@Overridepublic void onComplete() {} });compositeDisposable.dispose();

2:新增Flowable

Flowable<String> stringFlowable = Flowable.create(new FlowableOnSubscribe<String>() {@Overridepublic void subscribe(FlowableEmitter<String> e) throws Exception {e.onNext("1");e.onNext("2");e.onComplete();//e.onError(new NullPointerException()); }}, BackpressureStrategy.ERROR).subscribeOn(Schedulers.newThread()).observeOn(Schedulers.newThread());stringFlowable.subscribe(new Subscriber<String>() {@Overridepublic void onSubscribe(Subscription s) {//s.request(1);// 參數(shù)表示接受多少次onNext回調(diào).// 當(dāng)onNext回調(diào)次數(shù)和這個參數(shù)不一致時, 則通過BackpressureStrategy.ERROR參數(shù)決定之后的處理// 不調(diào)用等價于request(0).// 典型的錯誤MissingBackpressureException異常// 注意: Flowable請盡量在異步線程使用,否則很容易出現(xiàn)MissingBackpressureException異常 }@Overridepublic void onNext(String s) {}@Overridepublic void onError(Throwable t) {}@Overridepublic void onComplete() {} });

?

總結(jié)

以上是生活随笔為你收集整理的Android--RxJava2更新体验的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。