Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy intentando ejecutar una transacción de base de datos con el cliente SQL reactivo de Vertx en una coroutine. De alguna manera no puedo entender cómo puedo convertir el CompletableFuture al tipo deseado io.vertx.core.Future. ¿Hay algún método auxiliar o extensiones para hacer esto fácilmente? val client: PgPool … suspend fun . . . Read more
Quiero usar las corrutinas de Kotlin en mis transacciones del cliente SQL reactivo. Para simplificar, iba a usar la función auxiliar proporcionada io.vertx.mutiny.sqlclient.Pool#withTransaction mencionada en la documentación aquí. Dado que la función pasada no es una función de suspensión de corrutina, me está dando un error como Las funciones de . . . Read more
Tengo una aplicación basada en Vert.x. Cuando arroja excepciones, no hay números de línea, por ejemplo: at com.someapp.class1.a(Destino desconocido) at com.someapp.class1.a(Destino desconocido) at com.someapp.class2.a(Destino desconocido) at com.someapp.class2.a(Destino desconocido) at com.someapp.class3.a(Destino desconocido) at io.vertx.core.Future.lambda$compose$0(Future.java:227) at io.vertx.core.impl.FutureImpl.tryComplete(FutureImpl.java:125) at io.vertx.core.impl.FutureImpl.complete(FutureImpl.java:86) at io.vertx.core.impl.FutureImpl.handle(FutureImpl.java:151) at io.vertx.core.impl.FutureImpl.handle(FutureImpl.java:18) at io.vertx.core.impl.FutureImpl.setHandler(FutureImpl.java:79) at io.vertx.core.Future.lambda$compose$1(Future.java:270) at io.vertx.core.impl.FutureImpl.tryComplete(FutureImpl.java:125) at io.vertx.core.impl.FutureImpl.complete(FutureImpl.java:86) at . . . Read more
Tengo un método que devuelve un Future de la siguiente manera: private Future<void> generateChildSerial(RoutingContext context, Long createJobID) Después de insertar los datos en la base de datos, devuelvo el future de la siguiente manera: db .preparedQuery(sql) .executeBatch(batch, res -> { if (res.succeeded()) { // Procesar filas RowSet<row> rows = res.result(); . . . Read more
Soy nuevo en el mundo de la programación reactiva. Actualmente estoy trabajando en una aplicación Java reactiva utilizando la biblioteca Mutiny. Necesito desarrollar un bucle que espere a que la iteración anterior finalice para comenzar la próxima. Por ejemplo: List<><t>> uniList = new ArrayList<>(); for (T item : items) { . . . Read more