Skip to content

Instantly share code, notes, and snippets.

View vietj's full-sized avatar
🤖
Coding the Future

Julien Viet vietj

🤖
Coding the Future
View GitHub Profile
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

Proto centric

Given

service Greeter {
  rpc sayHello(HelloRequest) returns (HelloResponse);
}
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;" +