RxJava / RxBinding：如何处理RxView上的错误

我在
android中使用Rx
Java和RxBindings进行查看.以下是我正在做的事情的一个例子.

RxView.clicks(btMyButton).flatMap(btn -> {
        // another observable which can throw onError.
        return Observable.error(null);
    }).subscribe(object -> {
        Log.d("CLICK","button clicked");
    },error -> {
        Log.d("CLICK","ERROR");
    });

当我点击MyButton时,我使用flatMap返回另一个observable,它是一个网络调用,可以返回成功或错误.当它返回错误时我在错误块中处理它.但我无法再次点击该按钮.

如何处理错误并仍然可以再次单击按钮？

解决方法

GreyBeardedGeek就是现货.要明确你的一个选项,你可以使用.materialize()：

RxView.clicks(btMyButton).flatMap(btn -> {
        if (ok) 
            return someObservable.materialize();
        else 
            return Observable.error(new MyException()).materialize();
    }).subscribe(notification -> {
        if (notification.hasValue())
            Log.d("CLICK","button clicked");
        else if (notification.isOnError())
             Log.d("CLICK","ERROR");
    });

顺便说一句,不要将null传递给Observable.error().