Vert.x allows you to easily write non-blocking HTTP clients and servers.
Vert.x supports the HTTP/1.0, HTTP/1.1, HTTP/2 and HTTP/3 protocols.
The base API for HTTP is the same for HTTP/1.x, HTTP/2 and HTTP/3, specific API features are available for dealing with the protocol peculiarities.
| package io.vertx.tests.vertx; | |
| import io.vertx.test.core.AsyncTestBase; | |
| import org.junit.Test; | |
| import java.util.*; | |
| import java.util.concurrent.CountDownLatch; | |
| import java.util.concurrent.Executor; | |
| import java.util.concurrent.Executors; | |
| import java.util.concurrent.ThreadFactory; |
| package io.vertx.ext.web.codec.sse; | |
| import io.vertx.codegen.annotations.Nullable; | |
| import io.vertx.core.Future; | |
| import io.vertx.core.Handler; | |
| import io.vertx.core.Promise; | |
| import io.vertx.core.buffer.Buffer; | |
| import io.vertx.core.streams.ReadStream; | |
| import io.vertx.core.streams.WriteStream; | |
| import io.vertx.ext.web.codec.BodyCodec; |
| package io.vertx.core; | |
| import io.netty.channel.EventLoop; | |
| import io.vertx.core.internal.ContextInternal; | |
| import io.vertx.core.internal.VertxInternal; | |
| public class Main { | |
| public static void main(String[] args) { |
| [INFO] Waiting until Deployment 98d775f6-a276-42ed-af47-7e70e196d924 is validated | |
| [ERROR] | |
| Deployment 98d775f6-a276-42ed-af47-7e70e196d924 failed | |
| pkg:maven/io.vertx/vertx-codegen-json@5.0.0.CR8: | |
| - Dependency version information is missing | |
| - Developers information is missing | |
| - License information is missing | |
| - Project URL is not defined | |
| - Project description is missing |
| diff --git a/vertx-web-client/src/test/java/io/vertx/ext/web/client/WebClientTest.java b/vertx-web-client/src/test/java/io/vertx/ext/web/client/WebClientTest.java | |
| index 4426909..11761b6 100644 | |
| --- a/vertx-web-client/src/test/java/io/vertx/ext/web/client/WebClientTest.java | |
| +++ b/vertx-web-client/src/test/java/io/vertx/ext/web/client/WebClientTest.java | |
| @@ -970,10 +970,10 @@ public class WebClientTest extends WebClientTestBase { | |
| write(buffer, promise); | |
| return promise.future(); | |
| } | |
| - public void write(Buffer buffer, Handler<AsyncResult<Void>> handler) { | |
| + public void write(Buffer buffer, Promise<Void> promise) { |
| /* | |
| * Copyright (c) 2011-2024 Contributors to the Eclipse Foundation | |
| * | |
| * This program and the accompanying materials are made available under the | |
| * terms of the Eclipse Public License 2.0 which is available at | |
| * http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0 | |
| * which is available at https://www.apache.org/licenses/LICENSE-2.0. | |
| * | |
| * SPDX-License-Identifier: EPL-2.0 OR Apache-2.0 | |
| */ |
| <!DOCTYPE html> | |
| <html lang="en"> | |
| <head> | |
| <title>Perflab results</title> | |
| <style> | |
| body { | |
| font-family: monospace; | |
| font-size: 12pt; |
| @Test | |
| public void testPipeliningOrder() throws Exception { | |
| client.close(); | |
| client = vertx.createHttpClient(createBaseClientOptions() | |
| .setKeepAlive(true) | |
| .setMaxPoolSize(1) | |
| ); |
