Tag: RX-JAVA
val redisson = Redisson.create(config) val redissonRx = redisson.rxJava() redisson.getLocalCachedMap<string, user=””>(“users”, LocalCachedMapOptions.defaults()) // funciona redissonRx.getLocalCachedMap<string, user=””>(“users”, LocalCachedMapOptions.defaults()) // no existe tal método ¿Por qué no puedo usar Local Cached Map con RxJava? No puedo encontrar ninguna información sobre por qué esta función no estaría disponible en la API de Redisson RxJava.</string,></string,>
Quiero invocar un Completable después de otro. Es decir, cuando el primero termine, invocar el segundo y cuando el segundo termine, invocar el tercero. Ya he intentado diferentes cosas como andThen(), pero descubrí que no “espera” a que el Completable anterior termine, ya que se ejecuta en paralelo. Hasta ahora, . . . 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
Tengo 2 Flowables (uno de los cuales me está proporcionando elementos de VelocityNed y otro que he escrito para consumir elementos del primero); el problema es que no sé cómo hacer el segundo correcto, ya que todavía no me siento seguro con RxJava. Mi código de Flowable: private Flowable<float> getIAS(Flowable<velocityned> . . . Read more
Estoy intentando obtener todas las claves y luego obtener todos sus valores usando un ReactiveRedisTemplate en Spring Data Redis. (Sé que se prefiere scan, pero quiero mantenerlo simple por ahora, a menos que ese sea mi problema). Fragmento de código: @Service class Test { Logger logger = LoggerFactory.getLogger(Test.class); @Autowired private . . . Read more