[taxi/bus 2.5.1]修复bus定时任务

2022-01-26 15:15:28 +08:00
parent bf50aa3af7
commit 018c206f1a
1 changed files with 1 additions and 1 deletions
--- a/OCH/mogo-och-bus/src/main/java/com/mogo/och/bus/presenter/OchBusOrderModel.java
+++ b/OCH/mogo-och-bus/src/main/java/com/mogo/och/bus/presenter/OchBusOrderModel.java
@@ -154,7 +154,7 @@ public class OchBusOrderModel {
            return;
        }
        mBusOrdersDisposable = Observable.interval(OchBusConst.LOOP_DELAY,
-                OchBusConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS)
+                OchBusConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
                .map((aLong -> aLong + 1))
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())