¿Cómo puedo agregar de manera condicional una operación asincrónica en medio de una transmisión de RxJava?
Aquí hay una versión simplificada de lo que bash hacer (usando Kotlin y RxJava)
makeServerCall() .doOnNext { doStuff(it) } //TODO: if it == 0, call asyncOperation() and wait for its callback to fire //before running the rest of the stream. Otherwise immediately run the rest //of the stream .flatMap { observable1(it) observable2(it) Observable.merge( getSpotSearchObservable(observable1), getSpotSearchObservable(observable2) } .subscribeBy(onNext = { allDone() view? }) ¿Cómo aprieto la llamada a asyncOperation() y hago que el rest de la transmisión espere a que se asyncOperation() su callback, pero solo cuando se cumple una determinada condición? Parece que es probablemente una operación trivial en Rx, pero no viene a la mente ninguna solución obvia.
- Agregar subscribeOn () está cambiando el tipo de retorno de observable
- Para una function de Kotlin utilizada como expresión, ¿hay una forma concisa de operar y devolver un valor?
- Confusión de la syntax de Kotlin lambda
- Cómo notificar a Observable cuando finalice CountdownTimer
- ¿Cómo especificar la versión de RxJava al usar RxKotlin?
- RxAndroid, cómo detectar si observable ha finalizado la emisión
- RxJava - ¿Entradas de keyboard de contrapresión?
- RxJava2 Tal vez devuelva Observable vacío si no hay elemento
- OnComplete nunca se llamó con toSortedList () y groupBy ()
- ¿Cómo leer JSON desde Url usando kotlin Android?
- Cómo pasar nulo a un Observable con tipo anulable en RxJava 2 y Kotlin
- Inyectar constructor y object complementario
- ¿Expresar "súper" generics en los types funcionales de Kotlin?
¡FlatMap it!
.flatMap { if (it == 0) { return@flatMap asyncOperation() .ignoreElements() .andThen(Observable.just(0)) } return@flatMap Observable.just(it) } .flatMap { observable1(it) observable2(it) Observable.merge( getSpotSearchObservable(observable1), getSpotSearchObservable(observable2) ) }