package io.reactiverse.groovy.pgclient;
public class PgClient_GroovyStaticExtension {
public static io.reactiverse.pgclient.PgPool pool(io.reactiverse.pgclient.PgClient j_receiver, java.util.Map<String, Object> options) {
return io.vertx.core.impl.ConversionHelper.fromObject(io.reactiverse.pgclient.PgClient.pool(options != null ? new io.reactiverse.pgclient.PgPoolOptions(io.vertx.core.impl.ConversionHelper.toJsonObject(options)) : null));
}
public static io.reactiverse.pgclient.PgPool pool(io.reactiverse.pgclient.PgClient j_receiver, io.vertx.core.Vertx vertx, java.util.Map<String, Object> options) {
return io.vertx.core.impl.ConversionHelper.fromObject(io.reactiverse.pgclient.PgClient.pool(vertx,
options != null ? new io.reactiverse.pgclient.PgPoolOptions(io.vertx.core.impl.ConversionHelper.toJsonObject(options)) : null));
}
public static void connect(io.reactiverse.pgclient.PgClient j_receiver, io.vertx.core.Vertx vertx, java.util.Map<String, Object> options, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.reactiverse.pgclient.PgConnection>> handler) {
io.reactiverse.pgclient.PgClient.connect(vertx,
options != null ? new io.reactiverse.pgclient.PgConnectOptions(io.vertx.core.impl.ConversionHelper.toJsonObject(options)) : null,
handler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<io.reactiverse.pgclient.PgConnection>>() {
public void handle(io.vertx.core.AsyncResult<io.reactiverse.pgclient.PgConnection> ar) {
handler.handle(ar.map(event -> io.vertx.core.impl.ConversionHelper.fromObject(event)));
}
} : null);
}
}