sql >> Base de Datos >  >> RDS >> PostgreSQL

Transmisión obtenida de Postgres con jOOQ que no devuelve resultados de la clase

El objetivo de Java Stream La API es para que dicha transmisión se consuma como máximo una vez. No tiene ninguna función de almacenamiento en búfer, ni admite un modelo de transmisión basado en inserción como lo hacen las implementaciones de transmisión reactiva.

Puede agregar otra API a su pila, como p. Reactor (hay otros, pero dado que ya está utilizando Spring...), que admite el almacenamiento en búfer y la reproducción de secuencias para varios consumidores, pero eso no tiene nada que ver con jOOQ directamente y tendrá una gran influencia en la arquitectura de su aplicación.

Tenga en cuenta que ResultQuery de jOOQ extiende org.reactivestreams.Publisher y Flow.Publisher de JDK 9 para una mejor interoperabilidad con estos flujos reactivos.