actually stop keep-alive on closed connection

mostroverkhov · mostroverkhov · commit aa37d79dae41 · 2019-05-13T21:00:10.000+03:00
Signed-off-by: Maksym Ostroverkhov &lt;m.ostroverkhov@gmail.com&gt;
diff --git a/rsocket-core/src/main/java/io/rsocket/keepalive/KeepAliveHandler.java b/rsocket-core/src/main/java/io/rsocket/keepalive/KeepAliveHandler.java
@@ -25,7 +25,7 @@ public KeepAliveFramesAcceptor start(
         KeepAliveSupport keepAliveSupport,
         Consumer<ByteBuf> onSendKeepAliveFrame,
         Consumer<KeepAlive> onTimeout) {
-      duplexConnection.onClose().subscribe(v -> keepAliveSupport.stop());
+      duplexConnection.onClose().doFinally(s -> keepAliveSupport.stop()).subscribe();
       return keepAliveSupport
           .onSendKeepAliveFrame(onSendKeepAliveFrame)
           .onTimeout(onTimeout)
