Ending a Quic stream after the stream is closed should result in a failure.

Author: vietj

vertx-core/src/main/java/io/vertx/core/net/impl/quic/QuicStreamImpl.java

@@ -106,9 +106,16 @@ protected long sizeof(Object msg) {
   @Override
   public Future<Void> end() {
     PromiseInternal<Void> promise = context.promise();
-    writeToChannel(() -> {
-      ChannelFuture shutdownPromise = channel.shutdownOutput();
-      shutdownPromise.addListener(promise);
+    writeToChannel(new MessageWrite() {
+      @Override
+      public void write() {
+        ChannelFuture shutdownPromise = channel.shutdownOutput();
+        shutdownPromise.addListener(promise);
+      }
+      @Override
+      public void cancel(Throwable cause) {
+        promise.fail(cause);
+      }
     });
     return promise.future();
   }

vertx-core/src/test/java/io/vertx/tests/net/quic/QuicServerTest.java

@@ -813,6 +813,52 @@ private List<String> testKeyLogFile(File keyLogFile) throws Exception {
     }
   }
 
+  @Test
+  public void testWriteWhenClosed() throws Exception {
+    testWriteWhenClosed(true);
+  }
+
+  @Test
+  public void testEndWhenClosed() throws Exception {
+    testWriteWhenClosed(false);
+  }
+
+  private void testWriteWhenClosed(boolean write) throws Exception {
+    disableThreadChecks();
+    QuicServer server = QuicServer.create(vertx, serverOptions());
+    server.handler(conn -> {
+      conn.streamHandler(stream -> {
+        stream.closeHandler(v -> {
+          Future<Void> f;
+          if (write) {
+            f = stream.write("test");
+          } else {
+            f = stream.end();
+          }
+          f.onComplete(onFailure2(err -> {
+            testComplete();
+          }));
+        });
+        stream.handler(buff -> {
+          stream.close();
+        });
+      });
+    });
+    server.bind(SocketAddress.inetSocketAddress(9999, "localhost")).await();
+    QuicTestClient client = new QuicTestClient(new NioEventLoopGroup(1));
+    try {
+      client = new QuicTestClient(new NioEventLoopGroup(1));
+      QuicTestClient.Connection connection = client.connect(new InetSocketAddress(NetUtil.LOCALHOST4, 9999));
+      QuicTestClient.Stream stream = connection.newStream();
+      stream.create();
+      stream.write("ping");
+      await();
+    } finally {
+      client.close();
+      server.close().await();
+    }
+  }
+
   /*  @Test
   public void testSoReuse() throws Exception {