Ensure networking is not performed on main during Subscription creation.

fork-5.53.8
Alex Hart 2022-05-11 09:09:07 -03:00
rodzic 82d42c03f7
commit 8f52f803cf
1 zmienionych plików z 2 dodań i 0 usunięć

Wyświetl plik

@ -168,6 +168,7 @@ class DonationPaymentRepository(activity: Activity) : StripeApi.PaymentIntentFet
val localSubscriber = SignalStore.donationsValues().requireSubscriber() val localSubscriber = SignalStore.donationsValues().requireSubscriber()
return ApplicationDependencies.getDonationsService() return ApplicationDependencies.getDonationsService()
.cancelSubscription(localSubscriber.subscriberId) .cancelSubscription(localSubscriber.subscriberId)
.subscribeOn(Schedulers.io())
.flatMap(ServiceResponse<EmptyResponse>::flattenResult) .flatMap(ServiceResponse<EmptyResponse>::flattenResult)
.ignoreElement() .ignoreElement()
.doOnComplete { Log.d(TAG, "Cancelled active subscription.", true) } .doOnComplete { Log.d(TAG, "Cancelled active subscription.", true) }
@ -179,6 +180,7 @@ class DonationPaymentRepository(activity: Activity) : StripeApi.PaymentIntentFet
return ApplicationDependencies return ApplicationDependencies
.getDonationsService() .getDonationsService()
.putSubscription(subscriberId) .putSubscription(subscriberId)
.subscribeOn(Schedulers.io())
.flatMap(ServiceResponse<EmptyResponse>::flattenResult).ignoreElement() .flatMap(ServiceResponse<EmptyResponse>::flattenResult).ignoreElement()
.doOnComplete { .doOnComplete {
Log.d(TAG, "Successfully set SubscriberId exists on Signal service.", true) Log.d(TAG, "Successfully set SubscriberId exists on Signal service.", true)