Raj*_*Raj 5 java android observable kotlin rx-java
I am trying to call multiple API parallel using rxjava2 in Android. it's working as per the requirement but in case of any api throws exception it fails to give the response of other API's, so is there any way to call other API who returning success response.
private fun getStoreCouponData() {
val userObservable = repo2
.create<StoreCouponsApi>(StoreCouponsApi::class.java!!)
.getCoupons
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
val eventsObservable = repo2
.create<StoreCouponsApi>(StoreCouponsApi::class.java!!)
.storeInfo
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
val combined = Observable.zip<StoreCoupons, StoreCoupons, StoreList>(userObservable, eventsObservable,
BiFunction<StoreCoupons, StoreCoupons, StoreList> { response1, response2 -> StoreList(response1, response2) })
combined.subscribe(object : DefaultObserver<StoreList>() {
override fun onNext(s: StoreList) {
for (item in s.store!!.coupons!!) {
System.out.println(item.store)
}
}
override fun onError(e: Throwable) {
System.out.println(e)
}
override fun onComplete() {
}
})
println(combined)
}
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
92 次 |
| 最近记录: |