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

¿El método share().block() de Mono es no bloqueante?

Estoy en medio de aprender Spring WebFlux. Estoy utilizando una llamada REST utilizando el código siguiente para analizar la respuesta: private void parseJsonResponse(String folderId) throws IOException { Mono<objectnode> theresponseMono = webClient.get() .uri(“/some/uri”) .retrieve().bodyToMono(ObjectNode.class); ObjectNode node = new ObjectMapper().disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES) .readValue(theresponseMono.share().block().toString(), ObjectNode.class); //manejar el objeto node aquí….. } Pregunta: ¿Es theresponseMono.share().block() bloqueante . . . Read more

Cómo devolver Flux en ServerResponse en WebFlux

Tengo una capa Jdbc que devuelve Flux. Mientras devuelve los datos, el método fromPublisher acepta otras clases Serializable, pero no acepta Flux. Enfoque 1 public Mono<ServerResponse> getNames(final ServerRequest request) { Flux<String> strings = Flux.just(“a”, “b”, “c”); return ServerResponse.ok().contentType(APPLICATION_JSON) .body(fromPublisher(strings, String.class)); } El enfoque anterior devuelve “abc” combinado como una única . . . Read more

Convertir la respuesta del stream de la API Webflux a List

Soy muy nuevo en la programación reactiva. Estoy consumiendo una API de webflux que devuelve una respuesta de flujo (application/stream+json). Mi tarea es llamar a la API y convertir la respuesta en una Lista. Aquí está mi parte de código para llamar a la API: ClientResponse res = webClient.method(HttpMethod.GET) .uri(“uri”) . . . Read more