From d8a720567d351fb24fd0bb1bfbf5dbb5024fcaeb Mon Sep 17 00:00:00 2001
From: Ilia Kurtov <ilia.kurtov@touchin.ru>
Date: Mon, 29 May 2017 18:45:43 +0300
Subject: [PATCH] changed to one thread back

---
 .../core/observables/SequenceObservableExecutor.java        | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/main/java/ru/touchin/roboswag/core/observables/SequenceObservableExecutor.java b/src/main/java/ru/touchin/roboswag/core/observables/SequenceObservableExecutor.java
index ee37b6b..f884e82 100644
--- a/src/main/java/ru/touchin/roboswag/core/observables/SequenceObservableExecutor.java
+++ b/src/main/java/ru/touchin/roboswag/core/observables/SequenceObservableExecutor.java
@@ -26,6 +26,9 @@ public class SequenceObservableExecutor {
 
     @NonNull
     private final Scheduler sendingScheduler = Schedulers.from(Executors.newSingleThreadExecutor());
+    @NonNull
+    private final Scheduler executeScheduler = Schedulers.from(Executors.newSingleThreadExecutor(
+            new ProcessPriorityThreadFactory(Thread.MIN_PRIORITY)));
 
     @NonNull
     public Observable<?> execute(@NonNull final Observable<?> completable) {
@@ -53,8 +56,7 @@ public class SequenceObservableExecutor {
             scheduleSubscription = sendingScheduler.createWorker().schedule(() -> {
                 final CountDownLatch blocker = new CountDownLatch(1);
                 executeSubscription = completable
-                        //TODO understand how to change this to a single thread
-                        .subscribeOn(Schedulers.from(Executors.newSingleThreadExecutor(new ProcessPriorityThreadFactory(Thread.MIN_PRIORITY))))
+                        .subscribeOn(executeScheduler)
                         .doOnUnsubscribe(blocker::countDown)
                         .subscribe(Actions.empty(), subscriber::onError, subscriber::onCompleted);
                 try {