replay(1) removed from socket connection

2017-06-01 14:49:54 +03:00 · 2017-06-01 14:49:54 +03:00 · 24bcae7170
parent 4e30aa9fa7
commit 24bcae7170
1 changed files with 1 additions and 2 deletions
--- 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);