diff --git a/src/main/java/ru/touchin/templates/socket/SocketConnection.java b/src/main/java/ru/touchin/templates/socket/SocketConnection.java
index 9cd9a13..77a592a 100644
--- a/src/main/java/ru/touchin/templates/socket/SocketConnection.java
+++ b/src/main/java/ru/touchin/templates/socket/SocketConnection.java
@@ -151,8 +151,7 @@ public abstract class SocketConnection {
                                             socket.off(socketEvent.getName());
                                             messagesObservableCache.remove(socketEvent);
                                         }))
-                                .replay(1)
-                                .refCount();
+                                .publish();
                         messagesObservableCache.put(socketEvent, result);
                     }
                     observableSubscriber.onNext(result);