From ce7ceaf6ec439c8bfafedbe4a0f08838670c9f4a Mon Sep 17 00:00:00 2001
From: Eugene Schava <eschava@gmail.com>
Date: Fri, 28 Oct 2022 14:47:41 +0200
Subject: [PATCH] Disconnect emitter should be called even if user disconnects
 already closed websocket

---
 .../xchangestream/service/netty/NettyStreamingService.java       | 1 +
 1 file changed, 1 insertion(+)

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 {