|
|
|
@ -105,9 +105,13 @@ public class BillingClientImpl implements BillingClient, PurchasesUpdatedListene
|
|
|
|
purchases,
|
|
|
|
purchases,
|
|
|
|
Single.fromCallable(() -> billingClient.queryPurchases(SkuType.SUBS)),
|
|
|
|
Single.fromCallable(() -> billingClient.queryPurchases(SkuType.SUBS)),
|
|
|
|
(iaps, subs) -> {
|
|
|
|
(iaps, subs) -> {
|
|
|
|
if (subs.getResponseCode() == BillingResponse.OK) {
|
|
|
|
if (iaps.getResponseCode() != BillingResponse.OK) {
|
|
|
|
iaps.getPurchasesList().addAll(subs.getPurchasesList());
|
|
|
|
return iaps;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (subs.getResponseCode() != BillingResponse.OK) {
|
|
|
|
|
|
|
|
return subs;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
iaps.getPurchasesList().addAll(subs.getPurchasesList());
|
|
|
|
return iaps;
|
|
|
|
return iaps;
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|