有時候我們需要解綁訂閱,或者取消訂閱,?

這個時候就使用到了 Disposable.dispose()方法下面以一個案例說下使用方法

  //Disposable.dispose()切斷觀察者 與 被觀察者 之間的連接findViewById(R.id.rx_break_link).setOnClickListener(new View.OnClickListener() {@Overridepublic void onClick(View v) {//創(chuàng)建被觀察者 & 生產(chǎn)事件//create()作用是創(chuàng)建被觀察者對象,是最基本的操作符,只有創(chuàng)建//just()作用不能能創(chuàng)建還能發(fā)射對象等會通過案例對比下Observable.create(new ObservableOnSubscribe<String>() {@Overridepublic void subscribe(ObservableEmitter<String> emitter) {emitter.onNext("哈嘍! Rxjava");emitter.onNext("嗨! Rxjava");emitter.onNext("喂! Rxjava");emitter.onComplete();}//subscribe訂閱者連接觀察者和被觀察者//Observer 創(chuàng)建觀察者 & 定義響應事件的行為}).subscribe(new Observer<String>() {@Overridepublic void onSubscribe(Disposable d) {mDisposable = d;//對Disposable類變量賦值Log.d("-----rxjava", "開始采用subscribe連接");}@Overridepublic void onNext(String s) {if (s.equals("嗨! Rxjava")){mDisposable.dispose();}Log.d("-----rxjava", "對Next事件作出響應:" + s);}@Overridepublic void onError(Throwable e) {Log.d("-----rxjava", "對Error事件作出響應" + e);}@Overridepublic void onComplete(){Log.d("-----rxjava", "對onComplete事件作出響應:RxJava認識完成");}});}});

解綁之后效果圖

?

沒有解綁點擊的效果圖

總結

以上是生活随笔為你收集整理的RxJava 解除订阅---------Disposable.dispose()方法的全部內容，希望文章能夠幫你解決所遇到的問題。

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