From 8f52f803cf3cd1299ecf0ed150a0695b23bfa5ca Mon Sep 17 00:00:00 2001
From: Alex Hart <alex@signal.org>
Date: Wed, 11 May 2022 09:09:07 -0300
Subject: [PATCH] Ensure networking is not performed on main during
 Subscription creation.

---
 .../settings/app/subscription/DonationPaymentRepository.kt      | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/app/src/main/java/org/thoughtcrime/securesms/components/settings/app/subscription/DonationPaymentRepository.kt b/app/src/main/java/org/thoughtcrime/securesms/components/settings/app/subscription/DonationPaymentRepository.kt
index f689affa19..7c10056df9 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/components/settings/app/subscription/DonationPaymentRepository.kt
+++ b/app/src/main/java/org/thoughtcrime/securesms/components/settings/app/subscription/DonationPaymentRepository.kt
@@ -168,6 +168,7 @@ class DonationPaymentRepository(activity: Activity) : StripeApi.PaymentIntentFet
     val localSubscriber = SignalStore.donationsValues().requireSubscriber()
     return ApplicationDependencies.getDonationsService()
       .cancelSubscription(localSubscriber.subscriberId)
+      .subscribeOn(Schedulers.io())
       .flatMap(ServiceResponse<EmptyResponse>::flattenResult)
       .ignoreElement()
       .doOnComplete { Log.d(TAG, "Cancelled active subscription.", true) }
@@ -179,6 +180,7 @@ class DonationPaymentRepository(activity: Activity) : StripeApi.PaymentIntentFet
     return ApplicationDependencies
       .getDonationsService()
       .putSubscription(subscriberId)
+      .subscribeOn(Schedulers.io())
       .flatMap(ServiceResponse<EmptyResponse>::flattenResult).ignoreElement()
       .doOnComplete {
         Log.d(TAG, "Successfully set SubscriberId exists on Signal service.", true)