Update RoomPresenter.java

f5afa19e · Filipe de Lima Brito · b00237ca · f5afa19e
Commit f5afa19e authored Aug 28, 2017 by Filipe de Lima Brito
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletion

RoomPresenter.java .../chat/rocket/android/fragment/chatroom/RoomPresenter.java +3 -1

No files found.
--- a/app/src/main/java/chat/rocket/android/fragment/chatroom/RoomPresenter.java
+++ b/app/src/main/java/chat/rocket/android/fragment/chatroom/RoomPresenter.java
@@ -231,10 +231,12 @@ public class RoomPresenter extends BasePresenter<RoomContract.View>
  }

  private void getUserByUsername(String username) {
-    Disposable disposable = userRepository.getByUsername(username)
+    final Disposable disposable = userRepository.getByUsername(username)
            .distinctUntilChanged()
            .filter(Optional::isPresent)
            .map(Optional::get)
+            .subscribeOn(AndroidSchedulers.from(BackgroundLooper.get()))
+            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(view::showUserStatus, Logger::report);
    addSubscription(disposable);
  }