Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
No se puede usar un bean de ámbito de solicitud en un código de Reactor. Se enfrenta a la siguiente excepción: org.springframework.beans.factory.BeanCreationException: Error al crear el bean con nombre ‘scopedTarget.eventProcessor’: El ámbito ‘request’ no está activo para el hilo actual; considere definir un proxy de ámbito para este bean si . . . Read more
Tuve la sensación a partir de los tutoriales de que devolver algo throwable no debería cambiar el tipo de retorno del método. Aquí están mis intentos: Cuando uso handle, todo está bien hasta que agrego .timeout(), entonces el tipo de retorno de la función cambia a Flux<object>. private Flux<string> exampleHandle() . . . Read more
@GetMapping(value = “/download”) public Flux<databuffer> flux(ServerHttpResponse response) throws IOException { final Stream<integer> stream = Stream.iterate(1, i -> i + 1).limit(1000); String fileName = String.format(“%s.csv”, RandomStringUtils.randomAlphabetic(10)); response.getHeaders().set(HttpHeaders.CONTENT_DISPOSITION, “attachment; filename=” + fileName); response.getHeaders().setContentType(MediaType.APPLICATION_OCTET_STREAM); final Flux<databuffer> next = Flux.create(emitter -> { stream .map(i -> String.format(“%d”, i).getBytes(StandardCharsets.UTF_8)) .forEach(bytes -> { final DefaultDataBuffer dataBuffer = . . . Read more
Empecé a aprender Java Reactor 3. El siguiente código no puede producir ningún resultado. Flux.create(sink -> { sink.next(“generar un número: ” + Math.random() * 100); // sink.complete(); }).publishOn(Schedulers.elastic()) .subscribe( consumer -> System.out.println(Thread.currentThread().getName() + consumer), error -> System.out.println(“¡error!” + error), () -> { System.out.println(“¡tarea completada!”); });
Tenemos una aplicación que utiliza Spring WebFlux que utiliza Project Reactor. Ejecuté una evaluación de BlockHound para la aplicación y informó que las llamadas de bloqueo java.io.RandomAccessFile.readBytes se realizan en bibliotecas como hibernate-validator, orika mapper. hibernate-validator lee mensajes de error de su archivo ValidationMessages.properties. ¿Qué tan grave es el impacto . . . Read more