fixes

Signed-off-by: Oleh Dokuka <odokuka@vmware.com>
Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
Signed-off-by: OlegDokuka <odokuka@vmware.com>

Author: OlegDokuka

rsocket-test/src/main/java/io/rsocket/test/TransportTest.java

@@ -85,7 +85,7 @@ static String read(String resourceName) {
 
   @BeforeEach
   default void setup() {
-    Hooks.onOperatorDebug();
+    //    Hooks.onOperatorDebug();
   }
 
   @AfterEach
@@ -123,7 +123,7 @@ public String getMessage() {
         throw throwable;
       }
     } finally {
-      Hooks.resetOnOperatorDebug();
+      //      Hooks.resetOnOperatorDebug();
     }
   }
 

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

@@ -47,14 +47,8 @@ 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 -> {
-    //              if (!isDisposed()) dispose();
-    //            });
+
+    connection.channel().closeFuture().addListener(future -> sender.dispose());
 
     connection.outbound().send(sender.log("queue " + this)).then().subscribe();
   }

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

@@ -52,13 +52,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 -> {
-    //              if (!isDisposed()) dispose();
-    //            });
+    connection.channel().closeFuture().addListener(future -> sender.dispose());
 
     connection
         .outbound()