From 12d21bc2bdf6f1b372161afde871c187cd59de40 Mon Sep 17 00:00:00 2001
From: Elena Bobkova <elena.bobkova@touchin.ru>
Date: Thu, 1 Jun 2017 15:13:09 +0300
Subject: [PATCH] added refCount() to publish()

---
 .../java/ru/touchin/templates/socket/SocketConnection.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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);