Disconnect emitter should be called even if user disconnects already …

…closed websocket
knowm · Oct 28, 2022 · ce7ceaf · ce7ceaf
1 parent 037c121
commit ce7ceaf
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...e-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java b/...e-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 {