es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

Tag: SPRING-WEBFLUX

Flujo a OutputStream

Estoy descargando un archivo de una API REST y quiero pasarlo a mi aplicación Angular. Entonces, una función de descarga. Actualmente, el archivo descargado se escribe en un archivo utilizando DataBufferUtils y luego se pasa al flujo de salida de la respuesta. Pero ahora quiero que los datos de Flujo . . . Read more

FlatMap un Flux no ejecutado

Tengo una lista que contiene 240 elementos, esta lista tarda más de 1 hora en enviarse completamente usando un bucle “for”. List<Map<String, Object>> conventions = mapConventions(objects, referentialService); for(Map<String, Object> item : conventions) { webClient.post() .uri(configProperties.getUrl().getConvention() + CONVENTION) .bodyValue(objectMapper.convertValue(item, JsonNode.class)) .retrieve() .bodyToMono(String.class); } Así que seguí este artículo para enviarlo simultáneamente . . . Read more

Cuerpo de solicitud Mono o Flux en controlador WebFlux

¿Cuál es la diferencia entre un controlador que recibe una carga útil de Java regular y una carga útil reactiva? Por ejemplo, digamos que tengo los siguientes 2 puntos finales: @RestController public class MyController { @PostMapping public Flux<someobject> doThing(@RequestBody MyPayload playlod) { // realiza tareas que devuelven un flux – . . . Read more

Cómo iniciar sesión en Mono vacío

Digamos que tengo las siguientes líneas: repositorio.findUser(name = “John Doe”) .map { // Se encontró al usuario, continuar procesando } .switchIfEmpty( // Solo registrar que no se encontró al usuario ) Mi enfoque actual, que no es el mejor pero funciona, es simplemente colocar el registro en otra función y . . . Read more

Spring Boot + webflux: No se pudo resolver la vista con el nombre.

Necesito responder con datos de imagen en formato jpeg @Controller @RequestMapping(“/resource”) class ResourceController() { @GetMapping(“/thumbnail/{userFileId}/{group}/{index}”, produces = [MediaType.IMAGE_JPEG_VALUE]) suspend fun getThumbnail( @PathVariable userFileId: String, @PathVariable group: String, @PathVariable index: Int, response: ServerHttpResponse ) { val url = service.getThumbnailUrl(userFileId, group, index) ?: throw ResponseStatusException(HttpStatus.NOT_FOUND) response.headers.contentType = MediaType.IMAGE_JPEG response.statusCode = HttpStatus.OK streamResponse(url, . . . Read more