package io.reactiverse.groovy.pgclient;
public class PgStream_GroovyExtension {
public static io.reactiverse.pgclient.PgStream<java.lang.Object> handler(io.reactiverse.pgclient.PgStream<Object> j_receiver, io.vertx.core.Handler<java.lang.Object> handler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.handler(handler != null ? event -> handler.handle(io.vertx.core.impl.ConversionHelper.fromObject(event)) : null));
return j_receiver;
}
}