fixes

Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/TcpDuplexConnection.java

@@ -49,7 +49,7 @@ public final class TcpDuplexConnection extends BaseDuplexConnection {
   public TcpDuplexConnection(Connection connection) {
     this.connection = Objects.requireNonNull(connection, "connection must not be null");
 
-    connection.channel().closeFuture().addListener(future -> sender.dispose());
+    connection.channel().closeFuture().addListener(future -> sender.onComplete());
 
     connection
         .outbound()

rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/WebsocketDuplexConnection.java

@@ -53,7 +53,7 @@ public final class WebsocketDuplexConnection extends BaseDuplexConnection {
   public WebsocketDuplexConnection(Connection connection) {
     this.connection = Objects.requireNonNull(connection, "connection must not be null");
 
-    connection.channel().closeFuture().addListener(future -> sender.dispose());
+    connection.channel().closeFuture().addListener(future -> sender.onComplete());
 
     connection
         .outbound()