Cómo get el valor emitido desde el primer observable

Tengo un flujo como este

Observable.fromIterable(configuration.symbols) // list of data (for ex. 0, 1, 2, 3) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .flatMap { api.anotherCall( symbol = it) // emitted value .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) } .subscribe { res -> { Ln.i(res) // result, but it would be perfect to know this data + symbol as a second param } } 

Gracias por cualquier ayuda

ps syntax de Kotlin

Tienes que usar algo más que flatMap como zip ( doc ).
Con zip los dos observables se combinarán de dos en dos.

O puede continuar usando flatMap pero agregue un map en el segundo observable como:

 api.anotherCall(symbol = it) // emitted value .map { secondValue -> it to secondValue } .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) 

Entonces el observador final recibirá un Pair<> .

  • Error de compilation de error de coincidencia de tipo Kotlin: Requiere éxito <T>, Encontrado MyError
  • Convierte el código de RxJava a Kotlin correctamente
  • RxJava cómo agrupar elementos de una list en Map <Key, List <Value >>
  • Comportamiento con Kotlin Higher-Order Functions e interfaces de método único?
  • No se puede hacer que la API invoque urlfetch.Fetch en un hilo que no sea el hilo de request original ni un hilo creado por ThreadManager
  • RX java / Android cómo lograr este brindis en cada clic usando el operador de rebote
  • ¿Cómo puedo agregar de manera condicional una operación asincrónica en medio de una transmisión de RxJava?
  • llamar parte de la secuencia una vez con múltiples suscriptores?
  • Cómo escribir la testing adecuada para el repository de interfaz reactiva que devuelve Observable solo cuando hay algún evento, cómo simular el desencadenamiento de ese evento
  • RxJava zipCon error IDE en Kotlin con Android Studio 3.0
  • RxJava Observable a Completable, cómo evitar toBlocking ()