Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Digamos que tienes una propiedad calculada que filtra y ordena una matriz de valores según la entrada del usuario. Si el usuario comienza a filtrar valores de la matriz y el valor de ordenamiento cambia durante el cálculo del filtrado, ¿la propiedad calculada continuará ejecutando el filtrado o pasará a . . . Read more
Tengo un servicio que se comunica con otro servicio a través de REST. La llamada está envuelta en un Mono: return Mono.from(buildPublisher(requestDto)) .subscribeOn(Schedulers.boundedElastic()) .onErrorResume(e -> Mono.empty()) .map(this::mapResponse); Necesito hacer decenas de miles de llamadas a ese servicio, así que estoy llamando al método anterior desde aquí: return Flux.fromStream(hugeListOfObjects.stream()) .flatMap(serviceWhichReturnsMono::makeACallAndReturnMono); Funciona . . . Read more
Estoy tratando de hacer algo de nuevo aquí en el proyecto reactor que estoy seguro de que es súper sencillo para cualquiera de ustedes, gurús del proyecto reactor que estén ahí fuera! He estado buscando y rascándome con esto por un tiempo ahora, y siento que una vez más me . . . 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
Durante los últimos años he estado viendo cambios en el mundo de la “Programación/Sistema Reactivo”. Para implementar sistemas no bloqueantes, asíncronos y con presión trasera, estos son muy buenos candidatos. Pero a menudo trato de ver cuál(es) es el mejor entre Akka/ProjectReactor/RxJava/Vertx para construir sistemas reactivos y que también puedan . . . Read more