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
index b05b33a8..f50d3b4e 100644
--- 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) {