Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Quiero realizar una acción cada segundo mientras el Mono está activo. ¿Cuál es la mejor manera de hacer esto? Aquí hay una opción que funciona, pero parece ser una solución temporal: “`java // Alguna acción asíncrona de larga duración Mono<string> asyncAction = Mono.delay(Duration.ofSeconds(60)).map(d -> "Hola"); Mono<string> periodicAction = Flux.interval(Duration.ofSeconds(1)) .doOnNext(d . . . Read more
Esto es lo que intento lograr: Cuando alguien solicita `http://localhost/runIt`, me gustaría devolver datos de la caché que se actualizarán cada 6 segundos. A continuación, tengo un flujo (siempre el mismo que se almacena en el mapa) que se instancia por primera vez y comienza a emitir números 0,1,2,3,4… hasta . . . Read more
Tengo este fragmento de código: @PostMapping(value = {"/store"}) public Mono<ResponseEntity<StoreResponse>> store(@RequestPart("file") Mono<FilePart> file, @RequestPart("publicationId") String publicationId, @RequestPart("visible") String visible) throws Exception { return file .doOnNext(this::checkFile) .flatMap((f) -> this.saveFileToDatabase(UUID.fromString(publicationId), f.filename(), Boolean.parseBoolean(visible))) .then(Mono.just(ResponseEntity.ok().body(new StoreResponse("", "", "Trabajando", null)))) .onErrorReturn(ResponseEntity.internalServerError().body(new StoreResponse("No funciona", "", "Trabajando", null))); } Pregunta 1: Lo extraño de esto es que . . . Read more
Tengo un objeto de tipo class Employee { private String salary; private String empId; private String departmentId; private String status; } y un método que devuelve Flux , Document es de tipo org.bson.Document, ejemplo [ { “empId”: “B123”, “salary”: “1000”, “departmentId”: “winna”, “status”: “START” }, { “empId”: “A123”, “salary”: “2000”, . . . Read more
Me pregunto si hay una mejor manera de obtener una respuesta de error en WebClient de una manera que no implique usar un ObjectMapper adicional al llamar a onErrorResume? En mi WebClient: import org.springframework.web.reactive.function.client.WebClientResponseException.BadRequest // … .onErrorResume(BadRequest::class.java, badRequestToMyDto()) private fun badRequestToMyDto(): (BadRequest) -> Mono<out mydto=””> = { it: BadRequest -> . . . Read more