Tag: AIOINFLUX
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
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
¿Es razonable implementar el mapeo dinámico de fromTo (escuchando cambios) de manera reactiva? Posibles soluciones: – Estilo de bloqueo al viejo estilo – Caché como Caffeine, etc. – Collections.synchronizedList<><><string, string=””>>> y procesarlo en un flujo</string,>
Estaba preguntándome cómo escribir un archivo YAML de lanzamiento de Helm utilizando el gráfico oficial de Helm para Airflow y sobrescribiendo el archivo values.yaml. Estoy intentando utilizar este archivo de configuración para implementar Airflow con Flux en un clúster de Kubernetes. Intenté: apiVersion: helm.fluxcd.io/v1 kind: HelmRelease metadata: name: airflow namespace: . . . 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