diff --git a/xchange-stream-service-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java b/xchange-stream-service-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java
index <HASH>..<HASH> 100644
--- a/xchange-stream-service-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java
+++ b/xchange-stream-service-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java
@@ -298,6 +298,7 @@ public abstract class NettyStreamingService<T> extends ConnectableService {
                           .addListener(
                               f -> {
                                 LOG.info("Disconnected");
+                                disconnectEmitters.onNext(new Object());
                                 completable.onComplete();
                               });
                     });
[Streaming] adding subscription to disconnects