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
public class JDBCTxOp extends AbstractJDBCAction<Void> {
private final TxCommand op;
public JDBCTxOp(JDBCStatementHelper helper, TxCommand op, SQLOptions options) {
super(helper, options);
this.op = op;
}
@Override
private <T> void executeDirect(ContextInternal ctx, AbstractJDBCAction<T> action, Handler<AsyncResult<T>> handler) {
getConnection(ctx, ar1 -> {
Future<T> fut = Future.future();
fut.setHandler(ar2 -> ctx.runOnContext(v -> handler.handle(ar2)));
if (ar1.succeeded()) {
JDBCConnectionImpl conn = (JDBCConnectionImpl) ar1.result();
Tracer tracer = ctx.owner().tracer();
Object trace;
if (tracer != null) {
trace = tracer.sendRequest(ctx.localContextData(), action);
@vietj
vietj / StatementBenchmarks.java
Created November 8, 2019 18:14 — forked from mp911de/StatementBenchmarks.java
R2DBC Postgres benchmarks
/*
* Copyright 2019 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
Dear Committer:
The Eclipse Board of Directors approved changes to the Eclipse Intellectual
Property Policy on October 21, 2019. The most significant change relates to
how we will perform due diligence of leveraged Third Party Content (Section IV
B).
Motivation and Background:
The Eclipse IP Policy and Procedures date back to 2004. While we have made
Vertx vertx = Vertx.vertx();
HttpClient client = vertx.createHttpClient();
HttpServer server = vertx.createHttpServer();
server.requestHandler(req -> {
Trace trace = Trace.create(req);
HttpClientRequest clientReq = client.get("some-uri", ar -> {
trace.close();
});
trace.propagateTo(clientReq);
clientReq.end();
@Test
public void testCloseHandlerWhenConnectionEnds() throws Exception {
server.requestHandler(req -> {
req.response().closeHandler(v -> {
testComplete();
});
req.response().setChunked(true).write("some-data");
});
startServer(testAddress);
client.request(HttpMethod.GET, testAddress, DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/somepath", resp -> {
@vietj
vietj / 4m1.md
Last active July 26, 2019 07:48
title date template author draft
Eclipse Vert.x 4 milestone 1 released!
2019-07-26
post.html
vietj
false

We are extremely pleased to announce the first 4.0 milestone release of Eclipse Vert.x .

Tests run: 5, Failures: 5, Errors: 0, Skipped: 0, Time elapsed: 2.149 sec <<< FAILURE! - in io.vertx.pgclient.data.TsTypesExtendedCodecTest
test_tsquery_and_tsvector(io.vertx.pgclient.data.TsTypesExtendedCodecTest) Time elapsed: 0.017 sec <<< FAILURE!
junit.framework.AssertionFailedError: Expected that public abstract java.lang.Boolean io.vertx.sqlclient.Tuple.getBoolean(int) would not fail: expected:<true> but was:<false>
at io.vertx.pgclient.data.ColumnChecker.lambda$returns$0(ColumnChecker.java:180)
at io.vertx.pgclient.data.ColumnChecker.forRow(ColumnChecker.java:284)
at io.vertx.pgclient.data.TsTypesExtendedCodecTest.lambda$null$0(TsTypesExtendedCodecTest.java:27)
test_tsquery_array(io.vertx.pgclient.data.TsTypesExtendedCodecTest) Time elapsed: 0.032 sec <<< FAILURE!
org.junit.internal.ArrayComparisonFailure: Expected that public abstract java.lang.String[] io.vertx.sqlclient.Tuple.getStringArray(int) returns ['fat':AB & 'cat', 'super':*] instead of ['fat':AB & 'cats', 'super':*]: arrays first di
package io.vertx.mysqlclient;
import io.vertx.sqlclient.Row;
import io.vertx.sqlclient.Tuple;
import java.util.function.BiConsumer;
import java.util.function.Function;
public class Main {

BBQ fin d'année

20 personnes.

Saucisses (Nico)

  • 35 mergez et 35 saucisses de chez El Tayeb

Pain (Joel)