relaxes connection dispose to avoid dropped error

OlegDokuka · OlegDokuka · commit 1f7191456f29 · 2021-11-09T13:31:17.000+02:00
Signed-off-by: Oleh Dokuka &lt;oleh.dokuka@icloud.com&gt;
Signed-off-by: Oleh Dokuka &lt;odokuka@vmware.com&gt;
Signed-off-by: Oleh Dokuka &lt;oleh.dokuka@icloud.com&gt;
diff --git a/rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/TcpDuplexConnection.java b/rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/TcpDuplexConnection.java
@@ -64,7 +64,6 @@ public SocketAddress remoteAddress() {
 
   @Override
   protected void doOnClose() {
-    sender.dispose();
     connection.dispose();
   }
 
diff --git a/rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/WebsocketDuplexConnection.java b/rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/WebsocketDuplexConnection.java
@@ -69,7 +69,6 @@ public SocketAddress remoteAddress() {
 
   @Override
   protected void doOnClose() {
-    sender.dispose();
     connection.dispose();
   }
 

Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,6 @@ public SocketAddress remoteAddress() {`
`64`	`64`
`65`	`65`	`@Override`
`66`	`66`	`protected void doOnClose() {`
`67`		`- sender.dispose();`
`68`	`67`	`connection.dispose();`
`69`	`68`	`}`
`70`	`69`
Original file line number	Diff line number	Diff line change
`@@ -69,7 +69,6 @@ public SocketAddress remoteAddress() {`
`69`	`69`
`70`	`70`	`@Override`
`71`	`71`	`protected void doOnClose() {`
`72`		`- sender.dispose();`
`73`	`72`	`connection.dispose();`
`74`	`73`	`}`
`75`	`74`