Add missing createStream -> openStream rename in QuicConnectionInternal

Author: vietj

vertx-core/src/main/java/io/vertx/core/internal/quic/QuicConnectionInternal.java

@@ -17,7 +17,6 @@
 import io.vertx.core.Handler;
 import io.vertx.core.internal.ContextInternal;
 import io.vertx.core.net.QuicConnection;
-import io.vertx.core.net.QuicConnectionClose;
 import io.vertx.core.net.QuicStream;
 
 import java.util.function.Consumer;
@@ -41,11 +40,11 @@ public interface QuicConnectionInternal extends QuicConnection {
    */
   QuicConnectionInternal graceHandler(Handler<Void> handler);
 
-  Future<QuicStream> createStream(ContextInternal context);
+  Future<QuicStream> openStream(ContextInternal context);
 
-  Future<QuicStream> createStream(ContextInternal context, boolean bidirectional);
+  Future<QuicStream> openStream(ContextInternal context, boolean bidirectional);
 
-  Future<QuicStream> createStream(ContextInternal context, boolean bidirectional, Function<Consumer<QuicStreamChannel>, ChannelInitializer<QuicStreamChannel>> initializerProvider);
+  Future<QuicStream> openStream(ContextInternal context, boolean bidirectional, Function<Consumer<QuicStreamChannel>, ChannelInitializer<QuicStreamChannel>> initializerProvider);
 
   ChannelHandlerContext channelHandlerContext();
 

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

@@ -41,7 +41,6 @@
 import java.util.concurrent.TimeUnit;
 import java.util.function.Consumer;
 import java.util.function.Function;
-import java.util.function.Supplier;
 
 /**
  * @author <a href="mailto:[email protected]">Julien Viet</a>
@@ -197,29 +196,29 @@ public QuicConnection shutdownHandler(Handler<Duration> handler) {
   }
 
   @Override
-  public Future<QuicStream> createStream(ContextInternal context) {
-    return createStream(context, true);
+  public Future<QuicStream> openStream(ContextInternal context) {
+    return openStream(context, true);
   }
 
   @Override
   public Future<QuicStream> openStream(boolean bidirectional) {
-    return createStream(vertx.getOrCreateContext(), bidirectional);
+    return openStream(vertx.getOrCreateContext(), bidirectional);
   }
 
   @Override
-  public Future<QuicStream> createStream(ContextInternal context, boolean bidirectional) {
+  public Future<QuicStream> openStream(ContextInternal context, boolean bidirectional) {
     Function<Consumer<QuicStreamChannel>, ChannelInitializer<QuicStreamChannel>> initializerProvider =
       quicStreamChannelConsumer -> new ChannelInitializer<>() {
       @Override
       protected void initChannel(QuicStreamChannel ch) throws Exception {
         quicStreamChannelConsumer.accept(ch);
       }
     };
-    return createStream(context, bidirectional, initializerProvider);
+    return openStream(context, bidirectional, initializerProvider);
   }
 
   @Override
-  public Future<QuicStream> createStream(ContextInternal context, boolean bidirectional, Function<Consumer<QuicStreamChannel>, ChannelInitializer<QuicStreamChannel>> initializerProvider) {
+  public Future<QuicStream> openStream(ContextInternal context, boolean bidirectional, Function<Consumer<QuicStreamChannel>, ChannelInitializer<QuicStreamChannel>> initializerProvider) {
     Promise<QuicStream> promise = context.promise();
     VertxHandler<QuicStreamImpl> handler = VertxHandler.create(chctx -> new QuicStreamImpl(this, context, (QuicStreamChannel) chctx.channel(), streamMetrics, chctx));
     handler.addHandler(stream -> {

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

@@ -207,7 +207,7 @@ public void testStreamContextProvided() {
 
     QuicConnection connection = client.connect(SocketAddress.inetSocketAddress(9999, "localhost")).await();
 
-    QuicStream stream = ((QuicConnectionInternal)connection).createStream(workerContext).await();
+    QuicStream stream = ((QuicConnectionInternal)connection).openStream(workerContext).await();
 
     AtomicInteger cnt = new AtomicInteger();
     stream.handler(buff -> {