I have 2 separate observables that emit respectively success and error for a specific request. I'm w...

# rx

[iex]

I have 2 separate observables that emit respectively success and error for a specific request. I'm wrapping this in a new observable, that triggers the request and returns a Single with success/error state. Thinking about how to implement this. Something like

val successObservable: Observable<SomeType>
val errorObservable: Observable<AnotherType> // AnotherType can be mapped into a Throwable

request.flatMap { 
    // First event of successObservable OR errorObservable. successObservable -> just(event), errorObservable -> error(error)
}

Not sure what operators to use here, zip with take(1) and startsWith(none) crossed my mind but it doesn't feel right...

[MiSikora]

successObservable.ambWith(errorObservable).firstOrError()

[iex]

right. Thank you! I had figured amb. Need to map the observables too to Result (or another common type), since amb requires the types to be the same

[iex]

and then do a flatMap to map the result.success to .just and result.error to .error