RxJava (Kotlin), Observable.amb y PublishSubject no están disparando
Estamos intentando observar un intervalo de 15 onNext o cada vez que onNext en nuestro tema refreshEventsSubject , pero sin éxito.
El sujeto se inicia como tal
- RxJava- Gire Observable en Iterator, Stream o Sequence
- Inyectar constructor y object complementario
- RxJava2 Tal vez devuelva Observable vacío si no hay elemento
- Confusión de la syntax de Kotlin lambda
- Rx-Kotlin awaitTerminalEvent nunca se sube a Completo
private val refreshEventsSubject = PublishSubject<Long>()
Y luego tratamos de observarlo así
Observable.merge(Observable.interval(0, 15, TimeUnit.SECONDS), refreshEventsSubject) .subscribe { ... }
Obtenemos los events del intervalo cada 15 segundos, pero el sujeto no está disparando después de ejecutar
refreshEventsSubject.onNext(0)
Cualquier idea apreciada.
(Todo está escrito en Kotlin)
- La biblioteca de Kotlin 'rxkotlin-0.21.0.jar' tiene un formatting no compatible. Actualice la biblioteca o el complemento
- RxKotlin flattenAsObservable (): no coincide con el método de reference
- Llamada asincrónica para cada elemento dentro de una colección
- Cómo notificar a Observable cuando finalice CountdownTimer
- Obtiene N últimos objects emitidos por observables en RxJava2
- ¿Puedo crear un método de extensión Kotlin para agregar una suscripción rxJava a una suscripción compuesta?
- ¿Cómo puedo agregar de manera condicional una operación asincrónica en medio de una transmisión de RxJava?
- Spring 5 and Kotlin 1.1 Coroutines: Type rx.Scheduler no presente
¡Asegúrate de que no se refreshEventsSubject.onNext(0) desde tu hilo principal ya que puede causar lockings!
También use http://reactivex.io/documentation/operators/amb.html en lugar de fusionar, ya que fusionará dos events oppon llamando a Next en su tema.
Lea la documentation de AMB: http://reactivex.io/documentation/operators/amb.html
Específicamente, emit all of the items from only the first of these Observables to emit an item or notification .
El operador que está buscando es probablemente Observable.merge : http://reactivex.io/documentation/operators/merge.html
- El método de callback a menudo para reenviar el evento a Observable?
- Reaccionar a la llamada de actualización