[taxi/bus 2.5.1] 修复订单轮询

This commit is contained in:
wangmingjun
2022-01-26 10:47:58 +08:00
parent 2b50699418
commit 40824e822e

View File

@@ -38,7 +38,7 @@ public class OCHTaxiModelLoopManager {
}
Logger.i(TAG, "startInAndWaitOrdersLoop()");
mInAndWaitServiceDisposable = Observable.interval(OCHTaxiConst.LOOP_DELAY,
OCHTaxiConst.LOOP_PERIOD_2S, TimeUnit.MILLISECONDS)
OCHTaxiConst.LOOP_PERIOD_2S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
.map((aLong -> aLong + 1))
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())