Tag: SPRING-WEBFLUX
Recientemente cambié mi aplicación de webmvc a webflux e intenté configurar esto: @Configuration @EnableWebFlux public class WebConfig implements WebFluxConfigurer { @Override public void addCorsMappings(CorsRegistry registry) { registry.addMapping(“/**”) .allowedOrigins(“*”); } @Bean CorsWebFilter corsWebFilter() { var corsConfig = new CorsConfiguration(); corsConfig.setAllowedOrigins(List.of(“*”)); var source = new UrlBasedCorsConfigurationSource(); source.registerCorsConfiguration(“/**”, corsConfig); return new CorsWebFilter(source); } . . . Read more
Suponga que deseo una llegada de vuelo Flux. El Sink estaría basado en la siguiente clase: class Flight { String code; Date eta; boolean arrived; } Un Map de code -> Flight sería el Sink real. Nuevos vuelos pueden ser añadidos (emit) y eta puede cambiar (causando un emit). Las . . . Read more
Tengo un fragmento de código similar para programar una entrada/salida en un pool de hilos separado, pero desafortunadamente necesitamos su respuesta para decidir si proceder o no. private Response getItemsNonBlockingMethod(String id, final String path) { WebTarget webTarget = sampleServWebTarget .path(path).queryParam(“id”, id); Mono<response> responseMono = Mono.fromCallable(() -> { // La E/S . . . Read more
Estoy tratando de entender la programación reactiva y cómo funciona el bucle de eventos. Mientras pueda entender cuándo se envía una nueva solicitud HTTP a la aplicación, esta solicitud se divide en eventos. Y cada evento es manejado por este bucle de eventos y para cada evento se registra una . . . Read more