[rxrepo-core] Fixing live queries scheduling

slim-gears · Jul 2, 2019 · 009a717 · 009a717
1 parent b331817
commit 009a717
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/rxrepo-orientdb/src/main/java/com/slimgears/rxrepo/orientdb/OrientDbStatementExecutor.java b/rxrepo-orientdb/src/main/java/com/slimgears/rxrepo/orientdb/OrientDbStatementExecutor.java
@@ -108,8 +108,7 @@ public Observable<Notification<PropertyResolver>> executeLiveQuery(SqlStatement
                         Optional.ofNullable(res.newResult())
                                 .map(or -> OResultPropertyResolver.create(OrientDbSessionProvider.create(res::database), or))
                                 .orElse(null)))
-                .takeUntil(shutdown.andThen(Observable.just(0)))
-                .observeOn(scheduler);
+                .takeUntil(shutdown.andThen(Observable.just(0)));
     }
 
     private Observable<PropertyResolver> toObservable(Function<ODatabaseDocument, OResultSet> resultSetSupplier) {