一起Talk Android吧（第五百三十三：RxJava中断事件流）

Posted 2023-03-29 talk_8

文章目录

• 概念介绍
• 实现方法
• 示例代码

各位看官们大家好，上一回中咱们说的例子是"RxJava基本用法",本章回中介绍的例子是"

RxJava中断事件流

"。闲话休提，言归正转，让我们一起Talk android吧！

概念介绍

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

实现方法

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

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

示例代码

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

        Observer<String> observer = new Observer<String>() 
            Disposable disposable;
            @Override
            public void onSubscribe(@io.reactivex.rxjava3.annotations.NonNull Disposable d) 
                disposable = d;
                Log.d(TAG, "onSubscribe: "+d.isDisposed() );
            

            @Override
            public void onNext(@io.reactivex.rxjava3.annotations.NonNull String s) 
                Log.d(TAG, "onNext: "+s);
                if(s != null && s.equals("Event 2")) 
                    disposable.dispose();
                
            

            @Override
            public void onError(@io.reactivex.rxjava3.annotations.NonNull Throwable e) 
                Log.d(TAG, "onError: "+e.toString());
            

            @Override
            public void onComplete() 
                Log.d(TAG, "onComplete: ");
            
        ;

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

程序的运行结果如下:

   onSubscribe: false
   onNext: Event1
   onNext: Event2

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

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

        Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() 
            @Override
            public 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: false
   onNext: Event1
   onNext: Event2
   onError: java.lang.Exception: error

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

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

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

一起Talk Android吧（第五百三十一回：解决ViewPager2中的滑动冲突）

文章目录

• 概念介绍
• 实现思路
• 示例代码

各位看官们大家好，上一回中咱们说的例子是"事件拦截之外部拦截",本章回介绍的例子是"

解决ViewPage2中的滑动冲突

"。闲话休提，言归正转，让我们一起Talk Android吧！

概念介绍

我们在前面章回中介绍了View中事件拦截的两种方法：内部拦截和外部拦截，并且通过文字结合代码的方式进行了介绍。这两种方法是拦截事件的通用方法，也可以用来解决ViewPager中的滑动冲突，不过在ViewPager2中只能使用内部拦截法，因为ViewPager2不能被继承，所以无法在ViewPager2中拦截事件。

本章回中我们将介绍另外一种思路来解决ViewPager2中的滑动冲突：关闭ViewPager2的滑动功能。

实现思路

整体上还是使用内部拦截的思路，在ViewPager2中包含的子View中拦截事件，当按下事件(ACTION_DOWN)触发时关闭ViewPager2中的滑动功能，当弹起事件(ACTION_UP)触发时打开ViewPager2的滑动功能。这样就可以让ViewPager2中的子View响应用户事件，而不是让ViewPager2去滑动页面。

示例代码

  @Override
    public boolean onTouchEvent(MotionEvent event) 
        int action = event.getAction();

        ViewPager2 viewPager = ActivityViewPagerContainer.mViewPager;
        switch (action) 
            case MotionEvent.ACTION_DOWN:
                if(viewPager != null) 
                    Log.d("printData", "onTouchEvent:  down viewpage false");
                    viewPager.setUserInputEnabled(false);
                else 
                    Log.d("printData", "onTouchEvent:  down viewpage is null");
                

                break;
            case MotionEvent.ACTION_MOVE:
                break;
            case MotionEvent.ACTION_UP:
                if(viewPager != null) 
                    viewPager.setUserInputEnabled(true);
                    Log.d("printData", "onTouchEvent: up viewpage true");
                else 
                    Log.d("printData", "onTouchEvent: up viewpage is null");
                
                break;
        

上面的代码是List中的代码片段，我们的使用场景是一个Activiey中包含ViewPager2,该ViewPager2又包含了多个Fragment,在某个Fragment中包含List组件。我们利用内部拦截的思路在List中拦截用户事件，因此重写了List中的onTouchEvent()方法，重写该方法时使用了ViewPager2的setUserInputEnabled()方法来关闭和打开ViewPager2的滑动功能。

代码中使用的ViewPager2位于ActivityViewPagerContainer这个Activity中，我们将其义成了静态成员变量，因此可以直接使用类名来获取ViewPager2.

看官们，关于"解决ViewPager2中的滑动冲突"的例子咱们就介绍到这里，欲知后面还有什么例子，且听下回分解！