Update widget after sending message

moezbhatti · Nov 9, 2019 · e720ee9 · e720ee9
1 parent c1e2ef0
commit e720ee9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/domain/src/main/java/com/moez/QKSMS/interactor/SendMessage.kt b/domain/src/main/java/com/moez/QKSMS/interactor/SendMessage.kt
@@ -30,7 +30,8 @@ import javax.inject.Inject
 class SendMessage @Inject constructor(
     private val context: Context,
     private val conversationRepo: ConversationRepository,
-    private val messageRepo: MessageRepository
+    private val messageRepo: MessageRepository,
+    private val updateBadge: UpdateBadge
 ) : Interactor<SendMessage.Params>() {
 
     data class Params(
@@ -63,5 +64,6 @@ class SendMessage @Inject constructor(
             }
             .doOnNext { threadId -> conversationRepo.updateConversations(threadId) }
             .doOnNext { threadId -> conversationRepo.markUnarchived(threadId) }
+            .flatMap { updateBadge.buildObservable(Unit) } // Update the widget
 
 }