requested changes

32588833 · Akshat Jain · fc0e5f04 · 32588833
Commit 32588833 authored Dec 17, 2018 by Akshat Jain
Hide whitespace changes
Inline Side-by-side

Showing with 7 additions and 5 deletions

ChatRoomPresenter.kt ...rocket/android/chatroom/presentation/ChatRoomPresenter.kt +7 -5

No files found.
--- a/app/src/main/java/chat/rocket/android/chatroom/presentation/ChatRoomPresenter.kt
+++ b/app/src/main/java/chat/rocket/android/chatroom/presentation/ChatRoomPresenter.kt
@@ -172,11 +172,13 @@ class ChatRoomPresenter @Inject constructor(
    }
    private suspend fun subscribeRoomChanges() {
-        chatRoomId?.let {
+        withContext(CommonPool + strategy.jobs) {
-            manager.addRoomChannel(it, roomChangesChannel)
+            chatRoomId?.let {
-            for (room in roomChangesChannel) {
+                manager.addRoomChannel(it, roomChangesChannel)
-                dbManager.getRoom(room.id)?.let {
+                for (room in roomChangesChannel) {
-                    view.onRoomUpdated(roomMapper.map(chatRoom = it, showLastMessage = true))
+                    dbManager.getRoom(room.id)?.let {
+                        view.onRoomUpdated(roomMapper.map(chatRoom = it, showLastMessage = true))
+                    }
                }
            }
        }