0

我正在尝试创建一个具有 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);
    }

签名片段：

@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);
}

问题是，一旦我的片段被创建， .startWith 就会被触发，而无需用户单击按钮。之后，如果用户点击按钮，加载状态永远不会被调用（.startwith again），而只会调用成功（或错误）。我在这里想念什么？

再次感谢 ！

编辑：

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

另一个进程正在获取透明位图，但在添加 startWith 之后，我的可调用对象永远不会被调用。如果我把它拿出来，它就像一个魅力。

4

1 回答 1

1

这只是一个 RxJava 错误，与 Mosby 无关。

将.startWith(new SignatureViewState.LoadingState())（也许.onErrorReturn(SignatureViewState.ErrorState::new)）放入从 . 返回的 observable 中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 返回的 observable 仅在用户单击您的按钮后启动（因为 switchMap 仅在触发意图后触发）。

startWith()意思是“在你做真正的工作之前，先发出这个”。如果您像在原始代码中所做的那样应用 startWith() ，显然它是可观察的加载开始，但您真正想要的是“在保存签名之前，从加载状态开始”。因此startWith()必须是可观察的“保存签名”的一部分，而不是可观察的“主要”本身的一部分。

于 2017-06-20T21:49:23.043 回答