From 42ea59771a54d2591df0a6dd3936dda669be99ae Mon Sep 17 00:00:00 2001
From: gs <3129367635@qq.com>
Date: 星期一, 08 七月 2024 12:23:48 +0800
Subject: [PATCH] 会议统计接入增加，删除，修改接口
---
app_base/src/main/java/com/android/app_base/utils/RxUtils.java | 17 ++++++++++++++++-
1 files changed, 16 insertions(+), 1 deletions(-)
diff --git a/app_base/src/main/java/com/android/app_base/utils/RxUtils.java b/app_base/src/main/java/com/android/app_base/utils/RxUtils.java
index 2fc511b..661e8d3 100644
--- a/app_base/src/main/java/com/android/app_base/utils/RxUtils.java
+++ b/app_base/src/main/java/com/android/app_base/utils/RxUtils.java
@@ -1,15 +1,17 @@
package com.android.app_base.utils;
+import io.reactivex.FlowableTransformer;
import io.reactivex.Observable;
import io.reactivex.ObservableSource;
import io.reactivex.ObservableTransformer;
+import io.reactivex.Scheduler;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;
/**
* @author Ljj
* @date 2023.03.24. 17:42
-* @desc
+* @desc RxJava宸ュ叿绫�
*/public class RxUtils {
public static <T> ObservableTransformer<T, T> schedulersTransformer() {
@@ -17,7 +19,20 @@
.observeOn(AndroidSchedulers.mainThread());
}
+ public static <T> ObservableTransformer<T, T> io() {
+ return upstream -> upstream.subscribeOn(Schedulers.io());
+ }
+ private static <T> FlowableTransformer<T, T> schedulerTransformerF(Scheduler scheduler) {
+ return flowable ->
+ flowable
+ .subscribeOn(scheduler)
+ .observeOn(AndroidSchedulers.mainThread(), true);
+ }
+
+ public static <T> FlowableTransformer<T, T> ioF() {
+ return schedulerTransformerF(Schedulers.io());
+ }
--
Gitblit v1.9.1