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 0ff9bd7ff8..c21d6d9302 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,Schedulers.trampoline())
+                OchBusConst.LOOP_PERIOD_60S, TimeUnit.MILLISECONDS)
                 .map((aLong -> aLong + 1))
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
diff --git 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
index 1cb2abe29a..236dc08dd4 100644
--- 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
@@ -196,7 +196,7 @@ public class OchBusOrderModel {
             return;
         }
         mBusOrdersDisposable = Observable.interval(OchBusConst.LOOP_DELAY,
-                OchBusConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
+                OchBusConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS)
                 .map((aLong -> aLong + 1))
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
diff --git a/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/model/OCHTaxiModelLoopManager.java b/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/model/OCHTaxiModelLoopManager.java
index ad1d7d1b97..a58fc4b411 100644
--- a/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/model/OCHTaxiModelLoopManager.java
+++ b/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/model/OCHTaxiModelLoopManager.java
@@ -38,7 +38,7 @@ public class OCHTaxiModelLoopManager {
         }
         Logger.i(TAG, "startInAndWaitOrdersLoop()");
         mInAndWaitServiceDisposable = Observable.interval(OCHTaxiConst.LOOP_DELAY,
-                OCHTaxiConst.LOOP_PERIOD_2S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
+                OCHTaxiConst.LOOP_PERIOD_2S, TimeUnit.MILLISECONDS)
                 .map((aLong -> aLong + 1))
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
@@ -59,7 +59,7 @@ public class OCHTaxiModelLoopManager {
         }
         Logger.i(TAG, "startNewBookingOrderLoop()");
         mNewBookingOrderDisposable = Observable.interval(OCHTaxiConst.LOOP_DELAY,
-                OCHTaxiConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
+                OCHTaxiConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS)
                 .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,Schedulers.trampoline())
+                OCHTaxiConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS)
                 .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,Schedulers.trampoline())
+                OCHTaxiConst.LOOP_PERIOD_60S, TimeUnit.MILLISECONDS)
                 .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 f5f38a9bb2..f0bf44761a 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
@@ -38,7 +38,7 @@ public class OCHTaxiModelLoopManager {
         }
         Logger.i(TAG, "startInAndWaitOrdersLoop()");
         mInAndWaitServiceDisposable = Observable.interval(OCHTaxiConst.LOOP_DELAY,
-                OCHTaxiConst.LOOP_PERIOD_2S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
+                OCHTaxiConst.LOOP_PERIOD_2S, TimeUnit.MILLISECONDS)
                 .map((aLong -> aLong + 1))
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
@@ -59,7 +59,7 @@ public class OCHTaxiModelLoopManager {
         }
         Logger.i(TAG, "startNewBookingOrderLoop()");
         mNewBookingOrderDisposable = Observable.interval(OCHTaxiConst.LOOP_DELAY,
-                OCHTaxiConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS,Schedulers.trampoline())
+                OCHTaxiConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS)
                 .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,Schedulers.trampoline())
+                OCHTaxiConst.LOOP_PERIOD_1S, TimeUnit.MILLISECONDS)
                 .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,Schedulers.trampoline())
+                OCHTaxiConst.LOOP_PERIOD_60S, TimeUnit.MILLISECONDS)
                 .map((aLong -> aLong + 1))
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())