diff --git a/OCH/mogo-och-bus/src/main/java/com/mogo/och/bus/presenter/OchBusModelLoopManager.java b/OCH/mogo-och-bus/src/main/java/com/mogo/och/bus/presenter/OchBusModelLoopManager.java
index c21d6d9302..0ff9bd7ff8 100644
--- a/OCH/mogo-och-bus/src/main/java/com/mogo/och/bus/presenter/OchBusModelLoopManager.java
+++ b/OCH/mogo-och-bus/src/main/java/com/mogo/och/bus/presenter/OchBusModelLoopManager.java
@@ -35,7 +35,7 @@ public class OchBusModelLoopManager {
         }
         Logger.i(TAG, "startHeartbeatLoop()");
         mHeartbeatDisposable = Observable.interval(OchBusConst.LOOP_DELAY,
-                OchBusConst.LOOP_PERIOD_60S, TimeUnit.MILLISECONDS)
+                OchBusConst.LOOP_PERIOD_60S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
                 .map((aLong -> aLong + 1))
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
diff --git a/OCH/mogo-och-taxi/src/main/java/com/mogo/och/taxi/model/OCHTaxiModelLoopManager.java b/OCH/mogo-och-taxi/src/main/java/com/mogo/och/taxi/model/OCHTaxiModelLoopManager.java
index 0c49b20760..f5f38a9bb2 100644
--- a/OCH/mogo-och-taxi/src/main/java/com/mogo/och/taxi/model/OCHTaxiModelLoopManager.java
+++ b/OCH/mogo-och-taxi/src/main/java/com/mogo/och/taxi/model/OCHTaxiModelLoopManager.java
@@ -59,7 +59,7 @@ public class OCHTaxiModelLoopManager {
         }
         Logger.i(TAG, "startNewBookingOrderLoop()");
         mNewBookingOrderDisposable = Observable.interval(OCHTaxiConst.LOOP_DELAY,
-                OCHTaxiConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS)
+                OCHTaxiConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
                 .map((aLong -> aLong + 1))
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
@@ -80,7 +80,7 @@ public class OCHTaxiModelLoopManager {
         }
         Logger.i(TAG, "startGrabResultLoop()");
         mGrabResultDisposable = Observable.interval(OCHTaxiConst.LOOP_DELAY,
-                OCHTaxiConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS)
+                OCHTaxiConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
                 .map((aLong -> aLong + 1))
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
@@ -101,7 +101,7 @@ public class OCHTaxiModelLoopManager {
         }
         Logger.i(TAG, "startHeartbeatLoop()");
         mHeartbeatDisposable = Observable.interval(OCHTaxiConst.LOOP_DELAY,
-                OCHTaxiConst.LOOP_PERIOD_60S, TimeUnit.MILLISECONDS)
+                OCHTaxiConst.LOOP_PERIOD_60S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
                 .map((aLong -> aLong + 1))
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())