RxUtil 一个RxJava实用工具类的集合

怼烎@ 2022-05-30 07:49 252阅读 0赞

# RxUtil #

[![RxUtil][]][RxUtil 1] [![api][]][api 1]

一个实用的RxJava1工具类库

> 如果你使用的是RxJava2，请移步[RxUtil2][]

## 关于我 ##

[![github][]][github 1] [![csdn][]][csdn 1]

## 内容 ##

*  RxBus 支持多事件定义，支持数据携带，支持全局和局部的事件订阅和注销
 *  订阅池管理
 *  线程调度辅助工具
 *  RxBinding 使用工具类
 *  RxJava常用方法工具类

## 1、演示（请star支持） ##

### 1.1、RxBus ###

![RxBus][]

### Demo下载 ###

[![downloads][]][downloads 1]  
![这里写图片描述][70]

## 2、如何使用 ##

目前支持主流开发工具AndroidStudio的使用，直接配置build.gradle，增加依赖即可.

### 2.1、Android Studio导入方法，添加Gradle依赖 ###

先在项目根目录的 build.gradle 的 repositories 添加:

allprojects {
         repositories {
            ...
            maven { url "https://jitpack.io" }
        }
    }

然后在dependencies添加:

dependencies {
       ...
       implementation 'io.reactivex:rxjava:1.2.9'
       implementation 'io.reactivex:rxandroid:1.2.1'
       implementation 'com.github.xuexiangjys:RxUtil:1.1'
    }

### 3.1、RxBus使用 ###

#### 3.1.1、事件注册订阅 ####

1.使用RxBusUtils.get().onMainThread方法注册事件，并指定订阅发生在主线程。

RxBusUtils.get().onMainThread(EventKey.EVENT_HAVE_DATA, new Action1<Event>() {
        @Override
        public void call(Event event) {
            showContent(EventKey.EVENT_HAVE_DATA, event.toString());
        }
    });

2.使用RxBusUtils.get().on方法注册事件，订阅所在线程为事件发生线程，也可指定订阅发生的线程。

RxBusUtils.get().on(EventKey.EVENT_BACK_NORMAL, new Action1<String>() {
        @Override
        public void call(String eventName) {
            final String msg = "事件Key:" + EventKey.EVENT_BACK_NORMAL + "\n   EventName:" + eventName + ", 当前线程状态： " + Event.getLooperStatus();
            showContent(msg);
        }
    });

#### 3.1.2、事件发送 ####

1.使用RxBusUtils.get().post(Object eventName)发送不带数据的事件。

RxBusUtils.get().post(EventKey.EVENT_NO_DATA);

2.使用RxBusUtils.get().post(Object eventName, Object content)发送携带数据的事件。

RxBusUtils.get().post(EventKey.EVENT_HAVE_DATA, new Event(EventKey.EVENT_HAVE_DATA, "这里携带的是数据"));
    RxBusUtils.get().post(EventKey.EVENT_HAVE_DATA, true);

#### 3.1.3、事件注销 ####

1.使用RxBusUtils.get().unregisterAll(Object eventName)取消事件的所有订阅并注销事件。

RxBusUtils.get().unregisterAll(EventKey.EVENT_HAVE_DATA);

2.使用RxBusUtils.get().unregister(Object eventName, SubscribeInfo subscribeInfo)取消事件的某个指定订阅。  
SubscribeInfo是事件注册订阅后返回的订阅信息。如果在取消该订阅后，该事件如无其他订阅，便自动注销该事件。

RxBusUtils.get().unregister(EventKey.EVENT_CLEAR, mSubscribeInfo);

### 3.2、RxJavaUtils使用 ###

#### 3.2.1、线程任务 ####

1.RxIOTask：在io线程中操作的任务

RxJavaUtils.doInIOThread(new RxIOTask<String>("我是入参123") {
        @Override
        public Void doInIOThread(String s) {
            Log.e(TAG, "[doInIOThread]  " + getLooperStatus() + ", 入参:" + s);
            return null;
        }
    });

2.RxUITask：在UI线程中操作的任务

RxJavaUtils.doInUIThread(new RxUITask<String>("我是入参456") {
        @Override
        public void doInUIThread(String s) {
            Log.e(TAG, "[doInUIThread]  " + getLooperStatus() + ", 入参:" + s);
        }
    });

3.RxAsyncTask：在IO线程中执行耗时操作 执行完成后在UI线程中订阅的任务。

RxJavaUtils.executeAsyncTask(new RxAsyncTask<String, Integer>("我是入参789") {
        @Override
        public Integer doInIOThread(String s) {
            Log.e(TAG, "[doInIOThread]  " + getLooperStatus() + ", 入参:" + s);
            return 12345;
        }
    
        @Override
        public void doInUIThread(Integer integer) {
            Log.e(TAG, "[doInUIThread]  " + getLooperStatus() + ", 入参:" + integer);
        }
    });

4.RxIteratorTask:遍历集合或者数组的任务，在IO线程中执行耗时操作 执行完成后在UI线程中订阅的任务。

RxJavaUtils.executeRxIteratorTask(new RxIteratorTask<String, Integer>(new String[]{"123", "456", "789"}) {
        @Override
        public Integer doInIOThread(String s) {
            RxLog.e("[doInIOThread]" + getLooperStatus() + ", 入参:" + s);
            return Integer.parseInt(s);
        }
    
        @Override
        public void doInUIThread(Integer integer) {
            RxLog.e("[doInUIThread]  " + getLooperStatus() + ", 入参:" + integer);
        }
    });

#### 3.2.2、订阅者Subscriber ####

1.SimpleSubscriber：简单的订阅者，已对错误进行捕获处理，并对生命周期进行日志记录。可设置IExceptionHandler接口自定义错误处理，设置ILogger接口自定义日志记录。

2.ProgressLoadingSubscriber：带进度条加载的订阅者，实现IProgressLoader接口可自定义加载方式。

Observable.just("加载完毕！")
        .delay(3, TimeUnit.SECONDS)
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new ProgressLoadingSubscriber<String>(mProgressLoader) {
            @Override
            public void onNext(String s) {
                Toast.makeText(RxJavaActivity.this, s, Toast.LENGTH_SHORT).show();
            }
        });

### 3.3、SubscriptionPool使用 ###

SubscriptionPool：RxJava的订阅池

1.增加订阅：add(@NonNull Object tagName, Subscription m) 或者 add(Subscription m, @NonNull Object tagName)

SubscriptionPool.get().add(RxJavaUtils.polling(5, new Action1() {
        @Override
        public void call(Object o) {
            Toast.makeText(RxJavaActivity.this, "正在监听", Toast.LENGTH_SHORT).show();
        }
    }), "polling");

2.取消订阅：remove(@NonNull Object tagName)、remove(@NonNull Object tagName, Subscription m)、removeAll()

SubscriptionPool.get().remove("polling");

### 3.4、RxBindingUtils使用 ###

1.setViewClicks:设置点击事件

RxBindingUtils.setViewClicks(mBtnClick, 5, TimeUnit.SECONDS, new Action1<Void>() {
        @Override
        public void call(Void aVoid) {
            toast("触发点击");
        }
    });

2.setItemClicks:设置条目点击事件

### 3.5、RxSchedulerUtils使用 ###

1.  订阅发生在主线程 （ -> -> main)

.compose(RxSchedulerUtils.<T>_main())

1.  订阅发生在io线程 （ -> -> io)

.compose(RxSchedulerUtils.<T>_io())

1.  处理在io线程，订阅发生在主线程（ -> io -> main)

.compose(RxSchedulerUtils.<T>_io_main())

1.  处理在io线程，订阅也发生在io线程（ -> io -> io)

.compose(RxSchedulerUtils.<T>_io_io())

## 联系方式 ##

[![E7_82_B9_E6_88_91_E4_B8_80_E9_94_AE_E5_8A_A0_E5_85_A5QQ_E7_BE_A4-602082750-blue.svg][]][E7_82_B9_E6_88_91_E4_B8_80_E9_94_AE_E5_8A_A0_E5_85_A5QQ_E7_BE_A4-602082750-blue.svg 1]  
![20180411095210809][]

## 微信公众号 ##

![在这里插入图片描述][20190104152244834.jpg]

[RxUtil]: https://img.shields.io/badge/RxUtil-v1.1-brightgreen.svg
[RxUtil 1]: https://github.com/xuexiangjys/RxUtil
[api]: https://img.shields.io/badge/API-14+-brightgreen.svg
[api 1]: https://android-arsenal.com/api?level=14
[RxUtil2]: https://github.com/xuexiangjys/RxUtil2
[github]: https://img.shields.io/badge/GitHub-xuexiangjys-blue.svg
[github 1]: https://github.com/xuexiangjys
[csdn]: https://img.shields.io/badge/CSDN-xuexiangjys-green.svg
[csdn 1]: http://blog.csdn.net/xuexiangjys
[RxBus]: /images/20220530/22bd490420344c25b0455dd6919e1ea8.png
[downloads]: https://img.shields.io/badge/downloads-1.5M-blue.svg
[downloads 1]: https://github.com/xuexiangjys/RxUtil/blob/master/apk/rxutildemo.apk?raw=true
[70]: /images/20220530/78e7d6f6b0f24a358ad2a12ff3ba7b4d.png
[E7_82_B9_E6_88_91_E4_B8_80_E9_94_AE_E5_8A_A0_E5_85_A5QQ_E7_BE_A4-602082750-blue.svg]: https://img.shields.io/badge/%E7%82%B9%E6%88%91%E4%B8%80%E9%94%AE%E5%8A%A0%E5%85%A5QQ%E7%BE%A4-602082750-blue.svg
[E7_82_B9_E6_88_91_E4_B8_80_E9_94_AE_E5_8A_A0_E5_85_A5QQ_E7_BE_A4-602082750-blue.svg 1]: http://shang.qq.com/wpa/qunwpa?idkey=2c3af4151f887393c821dddcee43120be5dd1a54c43d0a7eb2b369c089bcc978
[20180411095210809]: /images/20220530/a3a8f4a99b4f4a8aa6955041a9b22b34.png
[20190104152244834.jpg]: /images/20220530/4e0b37a790354a47ad96e6360f732e7a.png