Given
service Greeter {
rpc sayHello(HelloRequest) returns (HelloResponse);
}
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) | |
); |
package org.creekservice.kafka.test.perf.performance; | |
public class Main { | |
public static void main(String[] args) throws Exception { | |
org.openjdk.jmh.Main.main(new String[]{ | |
JsonValidateBenchmark.class.getName() + ".measureDraft_04_Vertx", | |
"-prof", "async:" + | |
"libPath=/Users/julien/java/async-profiler-2.9-macos/build/libasyncProfiler.dylib;" + |
Use virtual threads to write Vert.x code that looks like it is synchronous.
You still write the traditional Vert.x code processing events, but you have the opportunity to write synchronous code for complex workflows and use thread locals in such workflows.