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 9303cd07df6..925d9ad1e53 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
@@ -329,6 +329,7 @@ public Completable disconnect() {
                 .addListener(
                     f -> {
                       connectionStateModel.setState(State.CLOSED);
+                      disconnectEmitters.onNext(new Object());
                       completable.onComplete();
                     });
           } else {