如何使用Rx更新鏈接請求上的UI Java

Question

我想在鏈接請求上更新UI 2次。

完成請求getUserByID()後首次更新UI。第二個getParentName()完成，但是當我嘗試更新第一個請求的UI並獲得線程問題的錯誤原因時。

我不知道如何解決這個問題。

示例代碼

API.getUserByID("USER ID") 
     .flatMap(user-> { 
      // How to update UI here? 
      return API.getParentName(user.getId())) 
     }) 
     .subscribeOn(Schedulers.io()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .subscribe(parent-> { 
      // It's ok to update UI cause of on main thread. 
      parentTextView.setText(parent.getName()) 
     }); 

謝謝。

Answer 1

您希望更新可觀察發射的UI，因此您需要爲該可觀察值指定觀察者線程。
那麼你應該使用doOnNext操作，即在觀察者線程調用：

API.getUserByID("USER ID") 
     .subscribeOn(Schedulers.io()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .doOnNext(user_ -> {calls on observer thread}) 
     .flatMap(user-> { 
      return API.getParentName(user.getId())) 
       .subscribeOn(Schedulers.io()) 
       .observeOn(AndroidSchedulers.mainThread()) 
     }) 
     .subscribe(parent-> { 
      // It's ok to update UI cause of on main thread. 
      parentTextView.setText(parent.getName()) 
     });