Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
He creado un Flux que utiliza subscribeOn(Subscribers.boundedElastic). Está envolviendo un Iterator que he creado. Lo que quisiera es que el Flux solicite el siguiente elemento en un hilo de trabajo mientras que el Subscriber está trabajando en el resultado actual. Idealmente, el Flux llamaría a hasNext() -> next() -> hasNext() . . . Read more
El código que tengo es este: return Flux.fromIterable(new Generator()).log() .flatMap( s -> webClient .head() .uri( MessageFormat.format( “/my-{2,number,#00}.xml”, channel, timestamp, s)) .exchangeToMono(r -> Mono.just(r.statusCode())) .filter(HttpStatus::is2xxSuccessful) .map(r -> s), 6) //solo solicitar 6 segmentos en paralelo a través de webClient .take(6) //solo necesitamos 6 respuestas 200 OK .sort(); Solo solicita HEAD, hasta . . . Read more
Tengo el siguiente flujo reactivo que obtiene datos de una API de terceros y luego popula un hashMap en paralelo. HashMap <String, List <String>> tempHashMap = new HashMap <>(); Flux.fromIterable(cList) .parallel(20) .runOn(Schedulers.boundedElastic()) .flatMap(cId -> { List <String> lb = api.getlb(p,cId); if(!lb.isEmpty()) { tempHashMap.put(cId, lb); } return Flux.just(tempHashMap); }) .sequential() .publishOn(Schedulers.single()) . . . Read more
Estoy escribiendo un marco de orquestación simple utilizando el framework Reactor, que ejecuta tareas en secuencia y la siguiente tarea a ejecutar depende del resultado de las tareas anteriores. Puedo tener varias opciones para elegir en función del resultado de las tareas anteriores. Anteriormente, escribí un marco similar basado en . . . Read more
Los elementos emitidos por Flux (en este caso “Rojo”, “Blanco”, “Azul”) se pasan a una llamada de servicio externo. Estoy obteniendo el valor de respuesta del servicio externo en returnValue. ¿Cómo puedo mapear los elementos enviados al servicio externo con la respuesta recibida?