minor changes

Author: whyoleg

rsocket-transports/netty-quic/src/jvmMain/kotlin/io/rsocket/kotlin/transport/netty/quic/NettyQuicStream.kt

@@ -60,6 +60,7 @@ internal class NettyQuicStream(
                         }
                     } finally {
                         outbound.cancel()
+                        // we dont' use `shutdownOutput` here as it will not flush buffered messages!
                         channel.writeAndFlush(QuicStreamFrame.EMPTY_FIN).awaitFuture()
                     }
                 }

rsocket-transports/netty-tcp/src/jvmMain/kotlin/io/rsocket/kotlin/transport/netty/tcp/NettyTcpConnection.kt

@@ -57,7 +57,7 @@ internal class NettyTcpConnection(
                         }
                     } finally {
                         outboundQueue.cancel()
-                        channel.shutdownOutput(channel.voidPromise())
+                        channel.shutdownOutput().awaitFuture()
                     }
                 }
             }
@@ -67,7 +67,7 @@ internal class NettyTcpConnection(
                 nonCancellable {
                     outboundQueue.close()
                     inbound.cancel()
-                    channel.shutdownInput(channel.voidPromise())
+                    channel.shutdownInput().awaitFuture()
                     outboundJob.join()
                     channel.close().awaitFuture()
                 }