在只發送屏幕上使用MVI

Question

我正嘗試創建一個窗體，具有SignaturePad的發送視圖，一旦用戶單擊保存按鈕，保存意圖被激發並執行一些後臺處理。

我有以下幾點：

主持人：

@Override 
    protected void bindIntents() { 
     Observable<SignatureViewState> observable = 
       intent(SignatureView::saveSignature) 
         .switchMap(intent -> Observable.fromCallable(() -> 
           storage.createFile(intent.getFullPath(), intent.getName(), intent.getImage())) 
           .subscribeOn(Schedulers.from(threadExecutor))) 
         .map(SignatureViewState.SuccessState::new) 
         .cast(SignatureViewState.class) 
         .startWith(new SignatureViewState.LoadingState()) 
         .onErrorReturn(SignatureViewState.ErrorState::new) 
         .observeOn(postExecutionThread.getScheduler()); 

     subscribeViewState(observable, SignatureView::render); 
    } 

SignatureFragment：

@Override 
    public void onViewCreated(View view, @Nullable Bundle savedInstanceState) { 
     saveButtonClickObservable = RxView.clicks(saveBtn) 
       .share() 
       .map(bla -> true); 

compositeDisposable.add(saveButtonClickObservable.subscribe()); 

...

@Override 
    public Observable<SaveSignatureIntent> saveSignature() { 
     Observable<SaveSignatureIntent> saveSignatureIntentObservable = 
       Observable.just(new SaveSignatureIntent(savePath, bookingId + ".png", null)); 

     Observable<SaveSignatureIntent> saveSignatureIntent = 
       Observable.zip(signatureBitmapObservable, saveSignatureIntentObservable, 
       (signature, intent) -> new SaveSignatureIntent(intent.fullPath, intent.name, signature)); 

     return saveButtonClickObservable 
       .flatMap(bla -> saveSignatureIntent); 
    } 

    @Override 
    public void render(SignatureViewState state) { 
     if(state instanceof SignatureViewState.LoadingState) 
      renderLoading(); 
     else if (state instanceof SignatureViewState.SuccessState) 
      renderSuccess(); 

     if(state instanceof SignatureViewState.ErrorState) 
      renderError(); 
    } 

最後我的看法：

public interface SignatureView extends MvpView { 
    Observable<SignatureFragment.SaveSignatureIntent> saveSignature(); 
    void render(SignatureViewState state); 
} 

問題是，一旦我的frag被創建，.startWith被觸發，而不需要用戶單擊按鈕。然後，如果用戶點擊按鈕，加載狀態永遠不會被調用（.start再次），但只有成功（或錯誤）。 我在這裏錯過了什麼？

再次感謝！

編輯：

signatureBitmapObservable = Observable.fromCallable(() -> signaturePad.getTransparentSignatureBitmap(true)) 
       .subscribeOn(Schedulers.io()) 
       .startWith(bla -> renderLoading()); 

另一個過程越來越透明位圖，但添加後startWith，我調用不會被調用。如果我把它拿出來，它就像魅力一樣。

Answer 1

這只是一個RxJava錯誤，並不真正與Mosby有關。

把.startWith(new SignatureViewState.LoadingState())（也許.onErrorReturn(SignatureViewState.ErrorState::new)）在從switchMap()返回的可觀察值。就像這樣：

intent(SignatureView::saveSignature) 
     .switchMap(intent -> Observable.fromCallable(() -> 
           storage.createFile(intent.getFullPath(), intent.getName(), intent.getImage())) 
           .subscribeOn(Schedulers.from(threadExecutor)) 
          .map(SignatureViewState.SuccessState::new) 
          .cast(SignatureViewState.class) 
          .startWith(new SignatureViewState.LoadingState()) 
          .onErrorReturn(SignatureViewState.ErrorState::new) 
     ) // end of switchMap 
     .observeOn(postExecutionThread.getScheduler()); 

可觀察到的從switchMap返回一旦用戶點擊這個按鈕，（因爲意圖已經被解僱後switchMap只觸發）纔開始。

startWith()意思是「在你做真正的工作之前，先發出它」。如果你應用startWith（），就像你在原始代碼中所做的那樣，顯然它是可加載的可觀察開始，但是你真正想要的是「在保存簽名之前，從加載狀態開始」。因此startWith()必須是「保存簽名」可觀察部分，而不是「主」可觀察本身。