Hey there, tried searching for this, but wasn't able to pull any results. What's the best way to take an Observable, FlatMapSingle to a Single Observable, but wait until we receive the result of the Single Observable, and decide to either complete or move onto the next one. For example:

getSomeObservable().flatMapSingle { t -> performAPICallWithData(t) }

I don't want to

performAPICallWithData

until the first one has completed, and I want to use the result from

performAPICallWithData

to determine wether I should perform the next one or complete everything

Could you do something like:

val observable = getSomeObservable().share()

observable.take(1).switchMap { t -> performApiCallWithData(t).flatMap { if (it.rightKindOfData) observable.skip(1) else Observable.empty() }

Thanks for the feedback! I ended up going with something like this for now

getSomeObservable().map { t ->
performApiCallWithData(t).blockingGet()
}.takeWhile {
 !it.rightKindOfData 
}.ignoreElements()

Seems to be working at the moment, although I'm open to alternative approaches. Does that make sense to you?

It does, though it's always best to work to avoid

blockingGet

since it defeats a bit part of the purpose. That being said if it works at this point I'd say it's fine.

It bugged me enough to spend more time on it, and I think the most elegant solution is using

concatMapSingleDelayError

which seems to work perfectly. it ends up like

getSomeObservable().concatMapSingleDelayError { t ->
performApiCallWithData(t)
}.takeWhile {
 !it.rightKindOfData 
}.ignoreElements()

awesome!