各位看官们大家好，上一回中咱们说的例子是"RxJava基本用法",本章回中介绍的例子是"
RxJava中断事件流"。闲话休提，言归正转，让我们一起Talk Android吧！

概念介绍

我们在上一章回中介绍了RxJava的基本用法，并且通过具体的示例代码进行了讲解，示例中的代码是一个完整的事件流，也就是说事件从开始一起运行到结束。本章回中
我们将介绍让事件流在运行过程中停止，或者说叫中断。因为中断事件很有必要，比如事件流运行过程中发生了错误，或者有其它突发的情况导致事件流无法运行。这些情况在程序中普遍存在，我们在编写程序时需要考虑这些情况。

实现方法

中断事件的实现方法有两种：

• 在观察者中使用Disposable的dispose()方法；
• 在被观察者中使用ObservableEmitter类的onError()方法；

示例代码

1. 在观察者中停止事件流或者叫中断事件流

        Observer<String> observer = new Observer<String>() {Disposable disposable;@Overridepublic void onSubscribe(@io.reactivex.rxjava3.annotations.NonNull Disposable d) {disposable = d;Log.d(TAG, "onSubscribe: "+d.isDisposed() );}@Overridepublic void onNext(@io.reactivex.rxjava3.annotations.NonNull String s) {Log.d(TAG, "onNext: "+s);if(s != null && s.equals("Event 2")) {disposable.dispose();}}@Overridepublic void onError(@io.reactivex.rxjava3.annotations.NonNull Throwable e) {Log.d(TAG, "onError: "+e.toString());}@Overridepublic void onComplete() {Log.d(TAG, "onComplete: ");}};

我们在onSubscribe()方法中获取到了Disposable类对象，在onNext()方法中判断事件中断的条件，符合事件中断条件时使用dispose()中断事件；

程序的运行结果如下:

   onSubscribe: falseonNext: Event1onNext: Event2

与完整的事件流程相比，没有打印"onNext:Event3"和"onComplete:",就是说这两个回调方法没有执行。

2. 在被观察者中停止事件流或者叫中断事件流

        Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {@Overridepublic void subscribe(@io.reactivex.rxjava3.annotations.NonNull ObservableEmitter<String> emitter) throws Throwable {emitter.onNext("Event 1");emitter.onNext("Event 2");emitter.onError(new Exception("error"));emitter.onNext("Event 3");emitter.onComplete();}});

我们在Event2事件分发后调用onError()方法中断事件流，程序的运行结果如下：

   onSubscribe: falseonNext: Event1onNext: Event2onError: java.lang.Exception: error

与完整的事件流程相比，没有打印"onNext: Event3"和"onComplete:",就是说这两个回调方法没有执行,而且比正常流程中多执行了onError()方法，这点从打印的log中可以看出来。

注意：不管使用哪个中断事件流的方法，事件流被中断后onComplete()方法将不会运行。

看官们，关于"RxJava中断事件流"的例子咱们就介绍到这里，欲知后面还有什么例子，且听下回分解！