Test Quic connection max idle timeout

Author: vietj

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

@@ -117,7 +117,7 @@ protected QuicCodecBuilder<?> initQuicCodecBuilder(ContextInternal context, SslC
     codecBuilder.initialMaxStreamDataUnidirectional(transportOptions.getInitialMaxStreamDataUnidirectional());
     codecBuilder.activeMigration(transportOptions.getActiveMigration());
     if (transportOptions.getMaxIdleTimeout() != null) {
-      codecBuilder.maxIdleTimeout(transportOptions.getMaxIdleTimeout().get(ChronoUnit.MILLIS), TimeUnit.MILLISECONDS);
+      codecBuilder.maxIdleTimeout(transportOptions.getMaxIdleTimeout().toMillis(), TimeUnit.MILLISECONDS);
     }
     if (transportOptions.isEnableDatagrams()) {
       codecBuilder.datagram(transportOptions.getDatagramReceiveQueueLength(), transportOptions.getDatagramSendQueueLength());

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

@@ -471,26 +471,24 @@ public void testReceiveDatagram() throws Exception {
     }
   }
 
-  @Ignore("Needs to add channel handler that drop packets")
   @Test
   public void testMaxIdleTimeout() throws Exception {
     QuicServerOptions options = serverOptions();
-    options.getTransportOptions().setMaxIdleTimeout(Duration.ofMillis(100));
+    options.getTransportOptions().setMaxIdleTimeout(Duration.ofMillis(1000));
     QuicServer server = QuicServer.create(vertx, options);
     server.handler(conn -> {
-      System.out.println("connected");
       long now = System.currentTimeMillis();
       conn.closeHandler(v -> {
-        System.out.println("closed " + (System.currentTimeMillis() - now));
+        assertTrue(System.currentTimeMillis() - now >= 1000);
+        assertTrue(System.currentTimeMillis() - now < 2000);
+        testComplete();
       });
     });
     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();
       await();
     } finally {
       client.close();