From 24bcae7170a88be197af264d15fcd66eadd764c6 Mon Sep 17 00:00:00 2001
From: Elena Bobkova <elena.bobkova@touchin.ru>
Date: Thu, 1 Jun 2017 14:49:54 +0300
Subject: [PATCH] replay(1) removed from socket connection

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

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