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