Resolve #224 Add scheduler parameter to toReactiveStore

requery · Jul 21, 2016 · df1eb3f · df1eb3f
1 parent 9c70d80
commit df1eb3f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/requery/src/main/java/io/requery/rx/RxSupport.java b/requery/src/main/java/io/requery/rx/RxSupport.java
@@ -45,7 +45,12 @@ private RxSupport() {
     }
 
     public static <S> SingleEntityStore<S> toReactiveStore(BlockingEntityStore<S> store) {
-        return new SingleEntityStoreFromBlocking<>(store);
+        return toReactiveStore(store, null);
+    }
+
+    public static <S> SingleEntityStore<S> toReactiveStore(BlockingEntityStore<S> store,
+                                                           Scheduler subscribeOn) {
+        return new SingleEntityStoreFromBlocking<>(store, subscribeOn);
     }
 
     public static <T> Observable<Result<T>> toResultObservable(final Result<T> result) {

diff --git a/requery/src/main/java/io/requery/rx/SingleEntityStoreFromBlocking.java b/requery/src/main/java/io/requery/rx/SingleEntityStoreFromBlocking.java
@@ -61,10 +61,6 @@ class SingleEntityStoreFromBlocking<T> extends SingleEntityStore<T> {
     private final ExecutorService executor;
     private final boolean createdExecutor;
 
-    SingleEntityStoreFromBlocking(BlockingEntityStore<T> delegate) {
-        this(delegate, null);
-    }
-
     SingleEntityStoreFromBlocking(BlockingEntityStore<T> delegate,
                                   @Nullable Scheduler subscribeOn) {
         this.delegate = Objects.requireNotNull(delegate);