diff --git a/src/main/java/ru/touchin/templates/socket/SocketConnection.java b/src/main/java/ru/touchin/templates/socket/SocketConnection.java index 4b5406d..227b933 100644 --- a/src/main/java/ru/touchin/templates/socket/SocketConnection.java +++ b/src/main/java/ru/touchin/templates/socket/SocketConnection.java @@ -156,8 +156,7 @@ public abstract class SocketConnection { observableSubscriber.onNext(result); observableSubscriber.onCompleted(); }) - .subscribeOn(scheduler) - .observeOn(Schedulers.computation())); + .subscribeOn(scheduler)); } /**